Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Moved Message into the new 'org.springframework.integration.core' package.

Browse Source
This commit is contained in:
Mark Fisher
2008-10-15 02:54:29 +00:00
parent ea2bb3e7c7
commit 08043b541d
252 changed files with 268 additions and 229 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageAggregator.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.aggregator;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrier.java
View File

@@ -24,7 +24,7 @@ import java.util.concurrent.locks.ReentrantLock;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Default implementation for a {@link MessageBarrier}.

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierConsumer.java
View File

@@ -31,8 +31,8 @@ import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.core.Message;
import org.springframework.integration.endpoint.AbstractMessageConsumer;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.integration.message.MessageProducer;

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AggregationBarrier.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.aggregator;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* MessageBarrier implementation for message aggregation. Delegates to a

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/CompletionStrategy.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.aggregator;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Strategy for determining when a group of messages reaches a state of

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/CompletionStrategyAdapter.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.aggregator;
import java.lang.reflect.Method;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageBarrier.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.aggregator;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Common interface for routing components that release a list of

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageListMethodAdapter.java
View File

@@ -23,7 +23,7 @@ import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessagingException;
import org.springframework.integration.util.DefaultMethodInvoker;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageSequenceComparator.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.aggregator;
import java.util.Comparator;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* A {@link Comparator} implementation based on the 'sequence number'

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MethodInvokingAggregator.java
View File

@@ -20,8 +20,8 @@ import java.lang.reflect.Method;
import java.util.List;
import org.springframework.integration.annotation.Aggregator;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.GenericMessage;
import org.springframework.integration.message.Message;
import org.springframework.integration.util.DefaultMethodResolver;
import org.springframework.integration.util.MethodResolver;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.aggregator;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageHeaders;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/ResequencingMessageBarrier.java
View File

@@ -22,7 +22,7 @@ import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* MessageBarrier implementation for resequencing. It can either

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/SequenceSizeCompletionStrategy.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.aggregator;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.util.CollectionUtils;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/annotation/Gateway.java
View File

@@ -30,7 +30,7 @@ import java.lang.annotation.Target;
* where the annotation attributes can override the default channel settings.
*
* <p>A method annotated with @Gateway may accept a single non-annotated
* parameter of type {@link org.springframework.integration.message.Message}
* parameter of type {@link org.springframework.integration.core.Message}
* or of the intended Message payload type. Method parameters may be mapped
* to individual Message header values by using the {@link Header @Header}
* parameter annotation. Alternatively, to pass the entire Message headers

2
org.springframework.integration/src/main/java/org/springframework/integration/annotation/Router.java
View File

@@ -28,7 +28,7 @@ import java.lang.annotation.Target;
* based on a message, message header(s), or both.
* <p>
* A method annotated with @Router may accept a parameter of type
* {@link org.springframework.integration.message.Message} or of the expected
* {@link org.springframework.integration.core.Message} or of the expected
* Message payload's type. Any type conversion supported by
* {@link org.springframework.beans.SimpleTypeConverter} will be applied to
* the Message payload if necessary. Header values can also be passed as

2
org.springframework.integration/src/main/java/org/springframework/integration/annotation/ServiceActivator.java
View File

@@ -27,7 +27,7 @@ import java.lang.annotation.Target;
* Indicates that a method is capable of handling a message or message payload.
* <p>
* A method annotated with @ServiceActivator may accept a parameter of type
* {@link org.springframework.integration.message.Message} or of the expected
* {@link org.springframework.integration.core.Message} or of the expected
* Message payload's type. Any type conversion supported by
* {@link org.springframework.beans.SimpleTypeConverter} will be applied to
* the Message payload if necessary. Header values can also be passed as

2
org.springframework.integration/src/main/java/org/springframework/integration/annotation/Splitter.java
View File

@@ -27,7 +27,7 @@ import java.lang.annotation.Target;
* payload to produce multiple messages or payloads.
* <p>
* A method annotated with @Splitter may accept a parameter of type
* {@link org.springframework.integration.message.Message} or of the expected
* {@link org.springframework.integration.core.Message} or of the expected
* Message payload's type. Any type conversion supported by
* {@link org.springframework.beans.SimpleTypeConverter} will be applied to
* the Message payload if necessary. Header values can also be passed as

2
org.springframework.integration/src/main/java/org/springframework/integration/aop/MessagePublishingInterceptor.java
View File

@@ -23,7 +23,7 @@ import org.apache.commons.logging.LogFactory;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultErrorChannel.java
View File

@@ -22,7 +22,7 @@ import org.apache.commons.logging.LogFactory;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.RendezvousChannel;
import org.springframework.integration.channel.interceptor.ChannelInterceptorAdapter;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* The default error channel implementation used by the {@link MessageBus}.

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/AbstractMessageChannel.java
View File

@@ -23,7 +23,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.BeanNameAware;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Base class for {@link MessageChannel} implementations providing common

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/AbstractPollableChannel.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.channel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Base class for all pollable channels.

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/AbstractSubscribableChannel.java
View File

@@ -16,8 +16,8 @@
package org.springframework.integration.channel;
import org.springframework.integration.core.Message;
import org.springframework.integration.dispatcher.MessageDispatcher;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/BlockingChannel.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.channel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Extends the base MessageChannel interface for channels that may block when a

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/ChannelInterceptor.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.channel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Interface for interceptors that are able to view and/or modify the

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/ChannelPurger.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.channel;
import java.util.ArrayList;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.selector.MessageSelector;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/MessageChannel.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.channel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Base channel interface defining common behavior for message sending and receiving.

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/MessageChannelTemplate.java
View File

@@ -24,7 +24,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.selector.MessageSelector;
import org.springframework.transaction.PlatformTransactionManager;

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/NullChannel.java
View File

@@ -21,7 +21,7 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.selector.MessageSelector;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/PollableChannel.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.channel;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.selector.MessageSelector;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/PriorityChannel.java
View File

@@ -21,7 +21,7 @@ import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessagePriority;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java
View File

@@ -22,7 +22,7 @@ import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.selector.MessageSelector;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/RendezvousChannel.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.channel;
import java.util.concurrent.SynchronousQueue;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* A zero-capacity version of {@link QueueChannel} that delegates to a

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/ThreadLocalChannel.java
View File

@@ -21,7 +21,7 @@ import java.util.List;
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.selector.MessageSelector;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/interceptor/ChannelInterceptorAdapter.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.channel.interceptor;
import org.springframework.integration.channel.ChannelInterceptor;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* A {@link ChannelInterceptor} with no-op method implementations so that

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/interceptor/MessageSelectingInterceptor.java
View File

@@ -20,7 +20,7 @@ import java.util.Arrays;
import java.util.List;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageDeliveryException;
import org.springframework.integration.selector.MessageSelector;

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/interceptor/MessageStoringInterceptor.java
View File

@@ -24,7 +24,7 @@ import org.apache.commons.logging.LogFactory;
import org.springframework.integration.channel.BlockingChannel;
import org.springframework.integration.channel.ChannelInterceptor;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageStore;
import org.springframework.integration.message.MessagingException;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/interceptor/WireTap.java
View File

@@ -23,7 +23,7 @@ import org.springframework.context.Lifecycle;
import org.springframework.integration.channel.BlockingChannel;
import org.springframework.integration.channel.ChannelInterceptor;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.selector.MessageSelector;
import org.springframework.util.Assert;

4
org.springframework.integration/src/main/java/org/springframework/integration/message/Message.java → org.springframework.integration/src/main/java/org/springframework/integration/core/Message.java
View File

@@ -14,7 +14,9 @@
* limitations under the License.
*/
package org.springframework.integration.message;
package org.springframework.integration.core;
import org.springframework.integration.message.MessageHeaders;
/**
* The central interface that any Message type must implement.

2
org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/AbstractDispatcher.java
View File

@@ -23,7 +23,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.core.task.TaskExecutor;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.integration.message.MessageRejectedException;

2
org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/BroadcastingDispatcher.java
View File

@@ -17,7 +17,7 @@
package org.springframework.integration.dispatcher;
import org.springframework.core.task.TaskExecutor;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.MessageConsumer;

2
org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/MessageDispatcher.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.dispatcher;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageConsumer;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/SimpleDispatcher.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.dispatcher;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.integration.message.MessageDeliveryException;
import org.springframework.integration.message.MessageRejectedException;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractMessageConsumer.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.endpoint;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.integration.message.MessagingException;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractMessageProducingEndpoint.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.endpoint;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractReplyProducingMessageConsumer.java
View File

@@ -22,7 +22,7 @@ import org.springframework.integration.channel.BeanFactoryChannelResolver;
import org.springframework.integration.channel.ChannelResolver;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.integration.message.MessageHeaders;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/ChannelPoller.java
View File

@@ -17,7 +17,7 @@
package org.springframework.integration.endpoint;
import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.integration.scheduling.Trigger;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/MessagingGateway.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.endpoint;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Base interface for gateway adapters. In Spring Integration, a "gateway" is a

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/PollingConsumerEndpoint.java
View File

@@ -17,7 +17,7 @@
package org.springframework.integration.endpoint;
import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/ReplyMessageHolder.java
View File

@@ -21,7 +21,7 @@ import java.util.Collections;
import java.util.List;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/ServiceActivatingConsumer.java
View File

@@ -20,7 +20,7 @@ import java.lang.reflect.Method;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.integration.message.MessageMappingMethodInvoker;
import org.springframework.integration.util.DefaultMethodResolver;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/SourcePollingChannelAdapter.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.endpoint;
import org.springframework.beans.factory.BeanNameAware;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageSource;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/filter/MessageFilter.java
View File

@@ -16,9 +16,9 @@
package org.springframework.integration.filter;
import org.springframework.integration.core.Message;
import org.springframework.integration.endpoint.AbstractReplyProducingMessageConsumer;
import org.springframework.integration.endpoint.ReplyMessageHolder;
import org.springframework.integration.message.Message;
import org.springframework.integration.selector.MessageSelector;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/filter/MethodInvokingSelector.java
View File

@@ -18,7 +18,7 @@ package org.springframework.integration.filter;
import java.lang.reflect.Method;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageMappingMethodInvoker;
import org.springframework.integration.selector.MessageSelector;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/gateway/AbstractMessagingGateway.java
View File

@@ -22,13 +22,13 @@ import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.channel.SubscribableChannel;
import org.springframework.integration.core.Message;
import org.springframework.integration.endpoint.AbstractReplyProducingMessageConsumer;
import org.springframework.integration.endpoint.MessageEndpoint;
import org.springframework.integration.endpoint.MessagingGateway;
import org.springframework.integration.endpoint.PollingConsumerEndpoint;
import org.springframework.integration.endpoint.ReplyMessageHolder;
import org.springframework.integration.endpoint.SubscribingConsumerEndpoint;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageConsumer;
import org.springframework.integration.message.MessageDeliveryException;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/gateway/GatewayProxyFactoryBean.java
View File

@@ -39,8 +39,8 @@ import org.springframework.integration.channel.ChannelResolver;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.config.xml.MessageBusParser;
import org.springframework.integration.core.Message;
import org.springframework.integration.endpoint.MessagingGateway;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MethodParameterMessageMapper;
import org.springframework.util.Assert;
import org.springframework.util.ClassUtils;

2
org.springframework.integration/src/main/java/org/springframework/integration/gateway/SimpleMessageMapper.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.gateway;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.InboundMessageMapper;
import org.springframework.integration.message.OutboundMessageMapper;

2
org.springframework.integration/src/main/java/org/springframework/integration/gateway/SimpleMessagingGateway.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.gateway;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.InboundMessageMapper;
import org.springframework.integration.message.OutboundMessageMapper;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/message/InboundMessageMapper.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* Strategy interface for mapping from an Object to a{@link Message}.
*

1
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageBuilder.java
View File

@@ -22,6 +22,7 @@ import java.util.Map;
import java.util.Set;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
import org.springframework.util.StringUtils;

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageConsumer.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* Base interface for any component that consumes Messages.
*

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageDeliveryAware.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* Interface that provides callback definitions for components that require
* message delivery status notifications.

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageDeliveryException.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* Exception that indicates an error during message delivery.
*

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageHandlingException.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* Exception that indicates an error during message handling.
*

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageHeaders.java
View File

@@ -24,6 +24,8 @@ import java.util.Map;
import java.util.Set;
import java.util.UUID;
import org.springframework.integration.core.Message;
/**
* The headers for a {@link Message}.
*

1
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageMappingMethodInvoker.java
View File

@@ -25,6 +25,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.core.Message;
import org.springframework.integration.util.DefaultMethodInvoker;
import org.springframework.integration.util.MethodInvoker;
import org.springframework.integration.util.NameResolvingMethodInvoker;

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageRejectedException.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* Exception that indicates a message has been rejected by a selector.
*

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageSource.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* Base interface for any source of {@link Message Messages} that can be polled.
*

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageStore.java
View File

@@ -18,6 +18,8 @@ package org.springframework.integration.message;
import java.util.List;
import org.springframework.integration.core.Message;
/**
* Strategy interface for storing and retrieving messages.
*

2
org.springframework.integration/src/main/java/org/springframework/integration/message/MessagingException.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* The base exception for any failures within the messaging system.
*

1
org.springframework.integration/src/main/java/org/springframework/integration/message/MethodInvokingConsumer.java
View File

@@ -18,6 +18,7 @@ package org.springframework.integration.message;
import java.lang.reflect.Method;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
/**

1
org.springframework.integration/src/main/java/org/springframework/integration/message/MethodInvokingSource.java
View File

@@ -20,6 +20,7 @@ import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.core.Message;
import org.springframework.integration.util.DefaultMethodInvoker;
import org.springframework.integration.util.MethodInvoker;
import org.springframework.integration.util.MethodValidator;

1
org.springframework.integration/src/main/java/org/springframework/integration/message/MethodParameterMessageMapper.java
View File

@@ -28,6 +28,7 @@ import org.springframework.core.MethodParameter;
import org.springframework.core.ParameterNameDiscoverer;
import org.springframework.integration.annotation.Header;
import org.springframework.integration.annotation.Headers;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;

2
org.springframework.integration/src/main/java/org/springframework/integration/message/OutboundMessageMapper.java
View File

@@ -16,6 +16,8 @@
package org.springframework.integration.message;
import org.springframework.integration.core.Message;
/**
* Strategy interface for mapping from a {@link Message} to an Object.
*

1
org.springframework.integration/src/main/java/org/springframework/integration/message/SimpleMessageStore.java
View File

@@ -20,6 +20,7 @@ import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.springframework.integration.core.Message;
import org.springframework.integration.util.BoundedHashMap;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/router/AbstractChannelNameResolvingMessageRouter.java
View File

@@ -25,7 +25,7 @@ import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.channel.BeanFactoryChannelResolver;
import org.springframework.integration.channel.ChannelResolver;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessagingException;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/router/AbstractMessageRouter.java
View File

@@ -20,8 +20,8 @@ import java.util.Collection;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.core.Message;
import org.springframework.integration.endpoint.AbstractMessageConsumer;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageDeliveryException;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/router/AbstractSingleChannelNameRouter.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.router;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Extends {@link AbstractChannelNameResolvingMessageRouter} to support router

2
org.springframework.integration/src/main/java/org/springframework/integration/router/AbstractSingleChannelRouter.java
View File

@@ -20,7 +20,7 @@ import java.util.Collection;
import java.util.Collections;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Extends {@link AbstractMessageRouter} to support router implementations that

2
org.springframework.integration/src/main/java/org/springframework/integration/router/ErrorMessageExceptionTypeRouter.java
View File

@@ -20,7 +20,7 @@ import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/router/MethodInvokingRouter.java
View File

@@ -25,7 +25,7 @@ import java.util.List;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.channel.ChannelResolver;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageMappingMethodInvoker;
import org.springframework.integration.message.MessagingException;
import org.springframework.util.Assert;

2
org.springframework.integration/src/main/java/org/springframework/integration/router/PayloadTypeRouter.java
View File

@@ -20,7 +20,7 @@ import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/router/RecipientListRouter.java
View File

@@ -21,7 +21,7 @@ import java.util.List;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/selector/MessageSelector.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.selector;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Strategy interface for message selection.

2
org.springframework.integration/src/main/java/org/springframework/integration/selector/MessageSelectorChain.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.selector;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/selector/PayloadTypeSelector.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.selector;
import java.util.ArrayList;
import java.util.List;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.util.Assert;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/selector/UnexpiredMessageSelector.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.selector;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* A {@link MessageSelector} that accepts {@link Message Messages} that are

2
org.springframework.integration/src/main/java/org/springframework/integration/splitter/AbstractMessageSplitter.java
View File

@@ -18,9 +18,9 @@ package org.springframework.integration.splitter;
import java.util.Collection;
import org.springframework.integration.core.Message;
import org.springframework.integration.endpoint.AbstractReplyProducingMessageConsumer;
import org.springframework.integration.endpoint.ReplyMessageHolder;
import org.springframework.integration.message.Message;
/**
* Base class for Message-splitting consumers.

2
org.springframework.integration/src/main/java/org/springframework/integration/splitter/DefaultMessageSplitter.java
View File

@@ -20,7 +20,7 @@ import java.util.ArrayList;
import java.util.List;
import java.util.StringTokenizer;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* The default Message Splitter implementation. Returns individual Messages

2
org.springframework.integration/src/main/java/org/springframework/integration/splitter/MethodInvokingSplitter.java
View File

@@ -20,7 +20,7 @@ import java.lang.reflect.Method;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.annotation.Splitter;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageMappingMethodInvoker;
import org.springframework.integration.util.DefaultMethodResolver;
import org.springframework.integration.util.MethodResolver;

2
org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractHeaderTransformer.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.transformer;
import java.util.HashMap;
import java.util.Map;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.MessagingException;

2
org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractPayloadTransformer.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.transformer;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.MessagingException;

2
org.springframework.integration/src/main/java/org/springframework/integration/transformer/MessageTransformingChannelInterceptor.java
View File

@@ -19,7 +19,7 @@ package org.springframework.integration.transformer;
import org.springframework.integration.channel.ChannelInterceptor;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.interceptor.ChannelInterceptorAdapter;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* A {@link ChannelInterceptor} which invokes a {@link Transformer}

2
org.springframework.integration/src/main/java/org/springframework/integration/transformer/MessageTransformingConsumer.java
View File

@@ -16,9 +16,9 @@
package org.springframework.integration.transformer;
import org.springframework.integration.core.Message;
import org.springframework.integration.endpoint.AbstractReplyProducingMessageConsumer;
import org.springframework.integration.endpoint.ReplyMessageHolder;
import org.springframework.integration.message.Message;
import org.springframework.util.Assert;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/transformer/MethodInvokingTransformer.java
View File

@@ -20,7 +20,7 @@ import java.lang.reflect.Method;
import java.util.Map;
import java.util.Properties;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.integration.message.MessageMappingMethodInvoker;

2
org.springframework.integration/src/main/java/org/springframework/integration/transformer/Transformer.java
View File

@@ -16,7 +16,7 @@
package org.springframework.integration.transformer;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
/**
* Strategy interface for transforming a {@link Message}.

2
org.springframework.integration/src/test/java/org/springframework/integration/aggregator/AggregationBarrierTests.java
View File

@@ -27,7 +27,7 @@ import org.junit.Test;
import org.springframework.integration.aggregator.AggregationBarrier;
import org.springframework.integration.aggregator.CompletionStrategy;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.StringMessage;
/**

2
org.springframework.integration/src/test/java/org/springframework/integration/aggregator/AggregatorEndpointTests.java
View File

@@ -35,7 +35,7 @@ import org.springframework.core.task.SimpleAsyncTaskExecutor;
import org.springframework.core.task.TaskExecutor;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.integration.message.StringMessage;

2
org.springframework.integration/src/test/java/org/springframework/integration/aggregator/CompletionStrategyAdapterTests.java
View File

@@ -25,8 +25,8 @@ import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.GenericMessage;
import org.springframework.integration.message.Message;
/**
* @author Marius Bogoevici

2
org.springframework.integration/src/test/java/org/springframework/integration/aggregator/MessageSequenceComparatorTests.java
View File

@@ -20,7 +20,7 @@ import static org.junit.Assert.assertEquals;
import org.junit.Test;
import org.springframework.integration.message.Message;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.StringMessage;

2
org.springframework.integration/src/test/java/org/springframework/integration/aggregator/MethodInvokingAggregatorTests.java
View File

@@ -25,8 +25,8 @@ import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.GenericMessage;
import org.springframework.integration.message.Message;
/**
* @author Marius Bogoevici

Some files were not shown because too many files have changed in this diff Show More