Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,025 Commits 25 Branches 0 Tags
68035e091daec90e9afbca5cf87449d7ad4fb3d9
Commit Graph

252 Commits

Author SHA1 Message Date
Mark Fisher
68035e091d Removed unused elements from XML schema. 2008-08-31 21:06:29 +00:00
Mark Fisher
5419a0b1d3 The MessageEndpoint interface no longer includes setters for 'source' and 'target'. AbstractEndpoint provides the setters, and the interface only defines the getters. 2008-08-31 15:52:42 +00:00
Mark Fisher
4fe5e95719 SubscriberAnnotationPostProcessor now creates ServiceActivatorEndpoints instead of DefaultEndpoints. 2008-08-31 14:26:16 +00:00
Mark Fisher
ea16a5f48c Removed channel and channel name properties from MessageEndpoint and its implementations. Now the MessageEndpoint only has the 'source' and 'target' properties. 2008-08-30 23:55:13 +00:00
Mark Fisher
f96354671c MessageEndpoint no longer has any awareness of the Schedule - only its MessageSource. The source may be a PollingDispatcher, but the poller is always configured without the MessageEndpoint needing to provide the Schedule. 2008-08-30 23:01:38 +00:00
Mark Fisher
bdfc98f966 Removed the aroundHandle() method from EndpointInterceptor now that the endpoints are simplified ("normal" AOP interception can easily be applied to the invoked target object). Removed the @Concurrency annotation since it was being applied by the endpointInterceptor instead of the poller and since the thread-pool executor is only one of the available taskExecutor options (may provide a 'taskExecutor' reference for @Poller instead). Removed the ConcurrencyInterceptor and TransactionInterceptor implementations. 2008-08-30 17:42:45 +00:00
Mark Fisher
41b3a764ab Added AbstractInOutEndpoint and ServiceActivatorEndpoint. SplitterEndpoint now extends AbstractInOutEndpoint as well. 2008-08-30 17:07:58 +00:00
Mark Fisher
37b4ee5bd7 Removed the "NEXT_TARGET" header, since it is no longer used by the Router implementations. Also, the MessagingAnnotationPostProcessor now considers any component annotated with a "stereotype" as a candidate for post-processing. 2008-08-28 20:49:45 +00:00
Mark Fisher
ba9c086aea Added Router strategy interface, and refactored Message-routing support in general to avoid MessageHandler. 2008-08-28 18:46:36 +00:00
Mark Fisher
62c7439960 MessagingAnnotationPostProcessor now requires the class-level @MessageEndpoint annotation. 2008-08-28 18:25:15 +00:00
Mark Fisher
5fd3ed90d3 Added Splitter strategy interface, and refactored Message-splitting support in general to avoid MessageHandler. 2008-08-27 23:00:27 +00:00
Mark Fisher
59c3d5c9e3 Moved the @Header annotation from the 'org.springframework.integration.handler.annotation' to the 'org.springframework.integration.annotation' package. 2008-08-27 21:21:57 +00:00
Mark Fisher
3061d6ed8a Moved channelRegistry property to AbstractEndpoint superclass instead of DefaultEndpoint, and removed the 'returnAddressOverrides' property as well as the corresponding XML attribute. 2008-08-27 19:21:56 +00:00
Mark Fisher
1f4acb82c8 Added tests for default splitter handling of Array and Collection payloads. 2008-08-25 14:03:49 +00:00
Mark Fisher
dedb3294e4 Removed IdGenerator strategy and RandomUuidGenerator implementation. We are always using UUID within GenericMessage. 2008-08-25 13:49:07 +00:00
Mark Fisher
50a227aaa1 The expirationDate header is now stored as a Long instead of a Date. 2008-08-25 13:44:25 +00:00
Marius Bogoevici
8a5b0c8832 INT-351 - nextTarget is now reset after a message has been sent. 2008-08-23 03:44:01 +00:00
Mark Fisher
fbfa5e03aa Setting default receiveTimeout to 1000 ms. 2008-08-20 05:46:55 +00:00
Mark Fisher
f3dd549723 Setting default receiveTimeout to 5000 ms instead of indefinite (-1). 2008-08-20 05:33:17 +00:00
Marius Bogoevici
78a5d9a7b3 Fixing javadoc. 2008-08-20 05:25:28 +00:00
Mark Fisher
05ce8ba7e3 Updated @Handler and @Publisher JavaDoc. 2008-08-20 05:02:19 +00:00
Mark Fisher
4be2fa45dd Added JavaDoc for @Aggregator. 2008-08-20 04:53:14 +00:00
Mark Fisher
218b100ab7 Moved the @Publisher annotation into the 'aop' package to avoid a cycle. 2008-08-20 04:42:43 +00:00
Mark Fisher
42e7a6bffa Added support for the "method" attribute on the <channel-adapter/> element in order to create MethodInvokingSource or MethodInvokingTarget instances. 2008-08-19 22:51:41 +00:00
Mark Fisher
42508cc231 Added some tests for MessageBuilder. 2008-08-19 21:50:32 +00:00
Marius Bogoevici
38bda54d4c Adding CronSchedule and parsing support for <poller cron="cronExpression"/>. Internal changes to the SPI. 2008-08-19 21:26:36 +00:00
Mark Fisher
54a78fcd72 Added JavaDoc for @Router and @Splitter (INT-273). 2008-08-19 18:24:42 +00:00
Mark Fisher
a43315e17e Added @Header parameter annotation test to SplitterMessageHandlerTests. 2008-08-19 18:21:52 +00:00
Mark Fisher
c00c13bdff Fixed issue with target ChannelAdapter when 'channel' is provided but <poller/> is not. 2008-08-19 17:05:19 +00:00
Mark Fisher
3f79525907 Updated MessageTarget JavaDoc (INT-331). 2008-08-19 16:07:36 +00:00
Mark Fisher
44e0c1c0c0 PublisherAnnotationPostProcessor now checks if any @Publisher annotations are defined on class methods only (rather than interfaces), and if so, the proxy will set the 'proxyTargetClass' property to 'true' prior to creating the proxy (INT-263). 2008-08-19 15:43:35 +00:00
Mark Fisher
d55c89e170 ChannelFactory is no longer tied to the MessageBus. Instead it will be discovered based on the bean name ("channelFactory"). The DefaultChannelFactoryBean no longer creates proxies. This also fixes INT-322. 2008-08-19 03:39:09 +00:00
Mark Fisher
c060e68fbc Added initial implementation of messaging bridge. 2008-08-19 02:02:57 +00:00
Mark Fisher
e472e64309 Added the "task-executor" attribute for the <message-bus/> element (INT-344). 2008-08-18 22:07:22 +00:00
Mark Fisher
b6ef9c8e1a Removed unnecessary initialize() call from registerEndpoint. 2008-08-18 21:10:58 +00:00
Mark Fisher
58c768541a Added namespace support for configuring an endpoint's ErrorHandler strategy. For example, the "error-handler" attribute can be provided on the <service-activator/> element with a bean name reference to any implementation of the ErrorHandler interface (INT-178). 2008-08-18 20:43:38 +00:00
Mark Fisher
0ec6cd61d9 SimpleDispatcher no longer continues to retry sending any time it catches an Exception. Instead, it will try to send to each of its targets until one of them accepts the message (returns true). If a target returns false (e.g. for a timeout) or throws a MessageRejectedException (e.g. a MessageSelector did not accept the Message), then it will continue trying its other targets. However, any other Exceptions will be re-thrown immediately. Also, it no longer attempts to send to its targets more than once. Thus, the 'rejectionLimit' and 'retryInterval' properties have been removed. The retry behavior actually belongs in an interceptor/template on a per-MessageTarget basis. Some targets are retry-able (e.g. might throw a RemoteAccessException), but others are not. Therefore, the SimpleDispatcher should not have this awareness; such configuration options belong with the individual target instead (part of INT-337). 2008-08-18 19:36:04 +00:00
Mark Fisher
b4701c0150 SimpleDispatcher no longer wraps a MessagingException inside of a MessageDeliveryException (part of INT-337). 2008-08-18 19:04:46 +00:00
Mark Fisher
30fd7decc8 Modified the 'onFailure' method signature in MessageDeliveryAware so that any Exception can be passed along with a separate Message parameter instead of always expecting a MessagingException. 2008-08-18 18:40:39 +00:00
Mark Fisher
80935d3bd0 Removed support for 'auto-create-channels' on the MessageBus. All channels must be explicitly created and registered with the bus (INT-247). 2008-08-18 17:36:13 +00:00
Mark Fisher
d8c4b0df69 Refactored common annotation value retrieval logic into a separate (private) method. 2008-08-18 16:34:27 +00:00
Mark Fisher
0fcf546ad0 Added support for publishing arguments, exception, or return value from the MessagePublishingInterceptor and the @Publisher-aware version (INT-175). 2008-08-18 15:53:42 +00:00
Mark Fisher
9b85225675 Channel Adapters are now endpoints, but if no "channel" attribute if provided for a <channel-adapter/> element, a DirectChannel will be created automatically. The <poller/> sub-element now belongs within the <channel-adapter/> (not the consumer endpoint downstream). This enables support for multiple Channel Adapters to share a MessageChannel. Also, the @Poller annotation belongs at class-level along with @ChannelAdapter if a @Pollable method is being adapted via MethodInvokingSource. 2008-08-17 22:37:35 +00:00
Iwein Fuld
d6aed95948 Finishing up INT-293, INT-154. Parametrized DefaultMessageMapper, refactored FtpSource to use a pool, added namespace support for FtpTarget. 2008-08-17 05:37:03 +00:00
Mark Fisher
8272a7d94c Added 'remove' functionality to the MessageHeaders (when setting a NULL value), and improved comments. 2008-08-15 18:20:11 +00:00
Mark Fisher
34710691aa Renamed MessageDispatcher's 'setTimeout' to 'setSendTimeout'. The more specific name is much clearer when the dispatcher is also being used for receive operations (e.g. PollingDispatcher). 2008-08-15 14:23:09 +00:00
Mark Fisher
73a848046a Removed the name parameter from channelRegistry.registerChannel() since the MessageChannel interface already defines getName(). Removed the setName() method from the MessageChannel interface. Removed the 'error-channel' attribute from the <message-bus/> element and the setErrorChannel() method from MessageBus. The "errorChannel" name is now sufficient for configuration. 2008-08-14 19:00:44 +00:00
Mark Fisher
824fff8381 Moved PollingDispatcher back into the 'dispatcher' package now that the cycle (with 'channel' and 'scheduling') has been removed. 2008-08-14 15:53:21 +00:00
Mark Fisher
1ce101f2bf Moved MessagePublishingErrorHandler from 'scheduling' package to 'channel'. 2008-08-14 15:47:12 +00:00
Mark Fisher
76762ed960 Moved DirectChannel and PublishSubscribeChannels to the 'channel' pacakge. 2008-08-14 15:40:13 +00:00