Commit Graph

162 Commits

Author SHA1 Message Date
Mark Fisher
0662b3edee Changed number of requests for multipleMessagesWithResponseCorrelator test. 2008-08-05 17:04:05 +00:00
Mark Fisher
82d353230b Increased test latch wait time. 2008-08-05 16:45:37 +00:00
Mark Fisher
a0b603b0fe The <poller/> element now accepts the "initial-delay" and "fixed-rate" (boolean) attributes (INT-326). 2008-08-05 16:37:32 +00:00
Mark Fisher
8e1c52b312 The MessageExchangeTemplate's receiveAndForward() method now throws the original Exception if it is a MessagingException. If it is not a MessagingException, then it will be wrapped within a new MessagingException (INT-325). 2008-08-05 15:31:22 +00:00
Mark Fisher
d929797867 Setting inputChannelName instead of source when <poller/> is not provided so that auto-create works (it does not apply with <poller/>). 2008-08-05 03:04:21 +00:00
Mark Fisher
de207c9bda PollingDispatchers are configured from the <poller/> element. The <schedule/> element has been removed. Instead the 'period' attribute is now available on <poller/>. 2008-08-05 02:52:52 +00:00
Mark Fisher
9f3e7d3d24 Removed EndpointTrigger, EndpointPoller, and EndpointVisitor. MessageBus now schedules PollingDispatchers for endpoints. 2008-08-05 01:59:35 +00:00
Mark Fisher
46b37df03d The MessageBus no longer calls registerChannels() from setApplicationContext(). Instead it maintains a reference to the applicationContext so that it can lookup channels on demand during startup. Then, the registerChannels() method is invoked after the ApplicationContext fires the ContextRefreshedEvent to register all channels that have not yet been registered. The AggregatorMessageHandlerCreator now performs type-safe retrieval from its attribute map. 2008-08-02 16:28:17 +00:00
Marius Bogoevici
e9050a8f82 Cosmetic changes 2008-08-02 15:32:06 +00:00
Mark Fisher
66835cb5ff Removed SimpleTaskScheduler. 2008-08-01 23:52:16 +00:00
Marius Bogoevici
4b42ea9de4 First cut at refactoring TaskScheduler: adding SPI interface and ScheduledExecutorService-based implementation. 2008-08-01 23:33:04 +00:00
Mark Fisher
98633cec5d updated EndpointInterceptorParser.java 2008-08-01 23:13:20 +00:00
Mark Fisher
951226346a The <channel-adapter/> now actually creates a channel instance rather than requiring another distinct channel object. Instead of configuring the poller on the channel-adapter, it is currently to be configured on the consuming endpoint just as if the <channel-adapter/> were any other pollable channel (e.g. <queue-channel/>). 2008-08-01 23:11:56 +00:00
Iwein Fuld
6f48cb218c cleaned up comment 2008-08-01 18:03:36 +00:00
Mark Fisher
0c38b88ad3 EndpointPoller now uses the MessageEndpoint's MessageExchangeTemplate. This allows poller transactions to work as configured on the endpoint's <poller/> sub-element. 2008-08-01 12:23:05 +00:00
Mark Fisher
d8375cd3a6 The targetMock expectation now returns true instead of null in 'multipleTargetsPartialTimeout()' test (avoids delayed NPE). 2008-07-31 13:52:35 +00:00
Mark Fisher
3a99b96966 Removed ChannelPublisher. MessageExchangeTemplate is sufficient. 2008-07-30 23:32:27 +00:00
Mark Fisher
fa58dc9457 Split MessageSource types into 2 sub-interfaces: PollableSource and SubscribableSource. The MessageChannel hierarchy has also been revised accordingly. DirectChannel and PublishSubscribeChannel are now SubscribableSources, while the other queue-based channels are PollableSources. The PollableChannel interface extends BlockingSource which in turn is an extension of PollableSource that adds timeout-aware methods. 2008-07-30 20:48:00 +00:00
Mark Fisher
35b77dabaf Removed setName from the MessageEndpoint interface, and the annotation post-processors now return AbstractEndpoint instead of MessageEndpoint. 2008-07-30 16:45:00 +00:00
Mark Fisher
b9bb70b634 Added support for 'apply-sequence' on <publish-subscribe-channel/>. The BroadcastingDispatcher has the 'applySequence' property (INT-321). 2008-07-30 16:02:47 +00:00
Mark Fisher
f30c1b73b2 Simplified AbstractHandlerEndpointParser and renamed AbstractEndpoint's setMessageSelector to setSelector (for consistency with setSource, setTarget, etc). 2008-07-30 14:06:37 +00:00
Mark Fisher
60cdfe4ffe Replacing RequestReplyTemplate with MessageExchangeTemplate. The ReplyMessageCorrelator delegation is now within the SimpleMessagingGateway. 2008-07-30 03:19:57 +00:00
Mark Fisher
a8075554ed Removed poll() method from AbstractEndpoint. 2008-07-30 01:37:21 +00:00
Mark Fisher
4a808803b9 Updated .classpath file for java mail version 1.4.1. 2008-07-29 23:52:22 +00:00
Mark Fisher
d3ed4a937a Added parser tests for the new MessageListener container attributes on the <jms-gateway/> element (INT-313). 2008-07-29 23:29:38 +00:00
Mark Fisher
83399a95cb Renamed the 'defaultReplyChannel' property to 'outputChannel' (and renamed the corresponding xml attributes) for the aggregator and resequencer. 2008-07-29 22:51:33 +00:00
Mark Fisher
07efae79e6 Added HeaderTransformer strategy interface and HeaderTransformingMessageHandler adapter (INT-307). 2008-07-29 21:19:55 +00:00
Mark Fisher
91226f8a34 MessageEndpoint now defines getSource() and getTarget() instead of getInputChannel() and getOutputChannel(). EndpointPoller now uses a MessageExchangeTemplate and MessageEndpoint no longer defines poll(). 2008-07-29 19:32:14 +00:00
Mark Fisher
57117efe41 Removed EndpointPolicy interface. 2008-07-29 02:32:39 +00:00
Mark Fisher
654a626419 Added MessageExchangeTemplate, AsyncMessageExchangeTemplate, and AsyncMessage. Removed Poller, SimplePoller, DefaultEndpointPoller, SourceInvoker, and TargetInvoker. 2008-07-28 23:42:50 +00:00
Mark Fisher
0ecda21ea2 HandlerEndpoint now accepts any MessageTarget as a 'returnAddress' rather than expecting a channel or channel-name. 2008-07-28 18:26:59 +00:00
Iwein Fuld
8932a56a18 added spring-test dependency to org.springframework.integration 2008-07-25 08:57:20 +00:00
Iwein Fuld
d257edf44e dispatcher tests added 2008-07-24 13:29:57 +00:00
Mark Fisher
a85f556bb8 Replaced <handler-endpoint/> with <service-activator/> in demos. 2008-07-19 03:31:11 +00:00
Mark Fisher
71dd2f2e80 Removed support for <handler-endpoint/> (replaced by <service-activator/>). 2008-07-19 03:23:23 +00:00
Mark Fisher
fcc5d56f81 Removed ReplyHandler. 2008-07-19 03:09:23 +00:00
Mark Fisher
0aa8aeb129 Refactored SimpleDispatcher and added test cases in SimpleDispatcherTests. Also removed MessageHandlerNotRunningException. 2008-07-18 23:00:03 +00:00
Mark Fisher
ce88e75725 Moved AbstractPayloadTransfomerParser into 'src/main' (instead of 'src/test'). 2008-07-18 20:34:45 +00:00
Mark Fisher
b37a4d8f12 Removed MessageTransformer due to the redundancy with MessageHandler (now that Messages are immutable). Refactored existing transformers to implement PayloadTransformer instead. All message handling is now the responsibility of the delegating PayloadTransformingMessageHandler. Also added the AbstractPaylaodTransformerParser from which all existing PayloadTransformer parsers now extend. 2008-07-18 20:12:59 +00:00
Marius Bogoevici
3a916b223d Fixes INT-305 - lazy initialization of DefaultChannelFactoryBean. 2008-07-18 19:59:00 +00:00
Mark Fisher
a9a498f3fc Added PayloadTransformer strategy interface, MethodInvokingPayloadTransformer, and PayloadTransformingMessageHandler. 2008-07-18 18:09:24 +00:00
Mark Fisher
9487837186 Refactored from @HeaderAttribute and @HeaderProperty to a single @Header annotation now that MessageHeaders contains a single map (INT-306). 2008-07-18 17:33:13 +00:00
Mark Fisher
7231e0867c Removed MessageBuilder copyHeadersFromMessage and copyHeaderFromMessageIfAbsent methods. 2008-07-18 13:13:23 +00:00
Mark Fisher
2c95306f63 Added MessageHeaders and MessageBuilder. Messages are now immutable (including header maps). 2008-07-17 22:58:56 +00:00
Mark Fisher
8dfe625163 Moved ChannelRegistryAware and InitializingBean interfaces to the AbstractEndpoint class declaration instead of the MessageEndpoint interface. 2008-07-16 01:38:41 +00:00
Mark Fisher
d344504e38 Message payload can no longer be set. MessageTransformer's transform() method now returns a Message (instead of void). ChannelInterceptor preSend() and postReceive() methods now return a Message instead of boolean. 2008-07-15 22:43:47 +00:00
Mark Fisher
0056edd10d Message timestamp is now a long (instead of java.util.Date). 2008-07-15 19:16:52 +00:00
Mark Fisher
cb7fe54f17 Only creating a DefaultEndpointPoller if the source is not a Subscribable channel. 2008-07-15 19:04:25 +00:00
Mark Fisher
b45514003c Implemented TriggerMessage with an EndpointPoller as its payload for convenience when triggering polling of an endpoint. 2008-07-14 23:11:54 +00:00
Mark Fisher
8f1cf63f5e Added support (in the schema) for the <poller/> sub-element within a <channel-adapter/> and added a setSource(MessageSource) method to DirectChannel. 2008-07-14 22:49:38 +00:00