Commit Graph

350 Commits

Author SHA1 Message Date
Mark Fisher
b160734ce1 Added AbstractOutboundChannelAdapterParser and MethodInvokingOutboundChannelAdapterParser. 2008-09-22 03:55:28 +00:00
Mark Fisher
a35a8e1143 Added a getDefaultPollInterval() method and a "default-default" value of 1000 (1 second). 2008-09-22 00:21:26 +00:00
Mark Fisher
870ab7b9f4 SimpleMessagingGateway now implements InitializingBean and verifies that the 'requestChannel' is not null. 2008-09-20 19:23:02 +00:00
Mark Fisher
a14246bfca Added AbstractChannelAdapterParser base class. 2008-09-19 23:24:15 +00:00
Mark Fisher
873bbbf7a6 Added abstract modifier. 2008-09-19 20:03:35 +00:00
Mark Fisher
2d66b2b67d Refactored MethodInvokingTarget to MethodInvokingConsumer including changes to OutboundChannelAdapter. 2008-09-19 19:55:47 +00:00
Mark Fisher
bbc14e5bbe SimpleMessagingGateway now supports a subscribable channel for its 'replyChannel'. However, when attempting to use the gateway for simple 'receive' operations, an exception will be thrown if the replyChannel is not a PollableChannel. The subscribable channel is only a relevant option when relying upon reply-message correlation. 2008-09-19 13:19:13 +00:00
Mark Fisher
045f96e2c0 Added AbstractSubscribablChannel base class for DirectChannel and PublishSubscribeChannel. 2008-09-19 12:33:22 +00:00
Mark Fisher
e0318d6132 Renamed AbstractInOutEndpoint to AbstractMessageHandlingEndpoint to be consistent with AbstractMessageProducingEndpoint and AbstractMessageConsumingEndpoint. 2008-09-19 12:00:42 +00:00
Mark Fisher
b1dfee7473 Renamed the 'processMessage' method to 'onMessageInternal' (it is the subclass implementation that is invoked from the base class 'onMessage' method). 2008-09-19 02:56:47 +00:00
Mark Fisher
866c9757e1 DefaultMessageBus simplifications. 2008-09-18 22:52:06 +00:00
Mark Fisher
eb5884a7d6 Removed EndpointRegistry. DefaultMessageBus now delegates to the ApplicationContext for all endpoint lookups, and the annotation-based post-processing registers singletons with the context rather than going through the DefaultMessageBus. 2008-09-18 22:42:08 +00:00
Mark Fisher
d8ebbe5994 Inbound Channel Adapter property is now "outputChannel" instead of just "channel". 2008-09-17 23:53:25 +00:00
Mark Fisher
8f9c709f25 Renamed InboundChannelAdapter to SourcePollingChannelAdapter since other event-driven inbound Channel Adapters may extend AbstractMessageProducingEndpoint directly. 2008-09-17 23:29:46 +00:00
Mark Fisher
baa1474ef9 InboundChannelAdapter now extends AbstractMessageProducingEndpoint. 2008-09-17 23:10:16 +00:00
Mark Fisher
6e56e8acbe Renamed MessageBuilder.fromPayload() to MessageBuilder.withPayload(). 2008-09-17 22:57:58 +00:00
Mark Fisher
6d4bc55520 Renamed AbstractProducerEndpoint to AbstractMessageProducingEndpoint (consistent with AbstractMessageConsumingEndpoint). 2008-09-17 22:36:50 +00:00
Mark Fisher
713c1a62db minor doc update 2008-09-17 21:53:20 +00:00
Mark Fisher
5a0677af00 Added AbstractPollingInboundChannelAdapterParser. 2008-09-17 21:30:12 +00:00
Mark Fisher
a2544f5b8e Added AbstractProducerEndpoint. 2008-09-17 19:16:19 +00:00
Mark Fisher
21d98f353d Removed 'handler' and 'handler-chain' elements from the XSD. 2008-09-17 12:41:29 +00:00
Mark Fisher
09f9161899 MessageBus interface no longer extends DisposableBean. Now, the DefaultMessageBus implementation implements DisposableBean directly. 2008-09-17 12:40:46 +00:00
Marius Bogoevici
3fb198f928 Adding an endpoint test for null-returning Aggregators 2008-09-17 04:33:15 +00:00
Marius Bogoevici
445a7e4e03 In completion to INT-369, adding test cases for null-returning and void-returning Aggregator methods. 2008-09-17 02:50:26 +00:00
Iwein Fuld
e59b11381b OPEN - issue INT-369: Nullpointer in AggregatingMessageHandler
http://jira.springframework.org/browse/INT-369
Added nullcheck and moved isEmpty check to MethodInvokingAggregator
2008-09-16 20:01:12 +00:00
Mark Fisher
473ac068d1 TaskScheduler no longer defines a setErrorHandler() method. 2008-09-15 14:11:29 +00:00
Mark Fisher
ccb9ba4197 Removed DefaultEndpointRegistry. The DefaultMessageBus now implements the EndpointRegistry interface directly. 2008-09-15 13:57:27 +00:00
Mark Fisher
82574606e1 Added 'default-output-channel' attribute to the <router/> element (INT-367). 2008-09-11 17:04:11 +00:00
Mark Fisher
e17bb4f11a Removed RetrievalBlockingMessageStore. 2008-09-11 14:32:50 +00:00
Mark Fisher
dfd6d42346 ReplyMessageCorrelator no longer delegates to a MessageStore. Instead, it simply passes to the Message's 'returnAddress' header (INT-366). 2008-09-11 14:22:07 +00:00
Iwein Fuld
0f9dc8c750 Complete - task 6: Create PollableFileSource
Last review done by Mark and Arjen, modification time concern pushed out.
Added parameter to MessageDeliveryAware
2008-09-11 13:40:12 +00:00
Mark Fisher
2a2d076b36 Renamed MessageExchangeTemplate to MessageChannelTemplate. 2008-09-09 10:36:29 +00:00
Mark Fisher
04bb57f58d MessageExchangeTemplate uses channels in all operations (rather than PollableSource) and no longer provides a receiveAndForward method. 2008-09-09 09:00:44 +00:00
Mark Fisher
ab2abb33d2 MessageExchangeTemplate uses channels in all operations (rather than PollableSource) and no longer provides a receiveAndForward method. 2008-09-09 08:54:07 +00:00
Mark Fisher
722f143244 DefaultMessageBus now sets channelRegistry only when activating endpoints (not when registering). 2008-09-08 16:51:34 +00:00
Mark Fisher
fb2c5f3237 RouterEndpoint no longer uses its own messageExchangeTemplate (no longer ignores settings on parent). 2008-09-08 16:50:00 +00:00
Mark Fisher
3c50a23d85 NullChannel now implements PollableChannel instead of MessageChannel only. 2008-09-08 16:49:05 +00:00
Mark Fisher
bef98c7f53 MessageChannel no longer extends MessageSource. 2008-09-07 22:06:55 +00:00
Mark Fisher
1e43e9439d Added 'task-executor' awareness to the AbstractEndpointParser for polling consumer endpoints. 2008-09-07 21:29:14 +00:00
Mark Fisher
bd7c74b69c Renamed SubscribableSource to Subscribable, and it no longer extends MessageSource. 2008-09-07 21:20:00 +00:00
Mark Fisher
35e744e60a Added AbstractMessageConsumingEndpoint. MessageDispatchers now expect MessageConsumer instances as subscribers, and the MessageEndpoint no longer has a send() method or a getSource() method. All consumer endpoints now use 'inputChannel' as the property (instead of source). The MessageBus is less involved in endpoint activation now, since endpoints that need to poll a channel can create, configure, and schedule their own poller. 2008-09-07 21:04:50 +00:00
Mark Fisher
7a92660993 Added TaskSchedulerAware interface. 2008-09-07 17:13:49 +00:00
Mark Fisher
299c93f2b3 Added MessageConsumer interface. 2008-09-07 17:13:26 +00:00
Mark Fisher
15f9875b5b Refactored PollingDispatcher into separate ChannelPoller and SourcePoller implementations with an AbstractPoller base class. 2008-09-07 15:23:17 +00:00
Mark Fisher
673d7d250b MessageEndpoint no longer extends the MessageTarget interface. 2008-09-07 01:48:34 +00:00
Mark Fisher
4eaec4ce68 Removed AbstractMessageHandler and DefaultMessageHandler. 2008-09-05 21:43:58 +00:00
Mark Fisher
bbd28e9817 Calling afterPropertiesSet() in post-processor if an endpoint was created. 2008-09-05 21:23:37 +00:00
Mark Fisher
e75fbeef76 MessageFilter is now an endpoint. 2008-09-05 21:04:01 +00:00
Mark Fisher
b2db1c0b16 Replaced the 'target' attribute with 'channel' on the <wire-tap/> element. 2008-09-05 17:44:08 +00:00
Mark Fisher
99f101e453 Moved the 'outputChannel' property from AbstractEndpoint to AbstractInOutEndpoint. 2008-09-05 17:35:19 +00:00