Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
885 Commits 25 Branches 0 Tags
a7acc623715023972b87b03f4c8174a4d364d409
Commit Graph

143 Commits

Author SHA1 Message Date
Mark Fisher
a7acc62371 Added CompositeMessage and added the 'nextTarget' header to MessageHeaders (and the corresponding methods in MessageBuilder). 2008-08-08 21:30:49 +00:00
Iwein Fuld
e88776463a tested and fixed onFailure for FtpSource 2008-08-08 14:56:51 +00:00
Mark Fisher
52f61b3d88 The PollingDispatcher's default receiveTimeout is now -1 for indefinite blocking. 2008-08-06 19:43:24 +00:00
Mark Fisher
528f5e6341 The @Polled annotation has been renamed @Poller (it no longer applies directly to a method). 2008-08-05 21:30:44 +00:00
Mark Fisher
1e82a8d568 Removed SourceEndpoint. Also, MessageExchangeTemplate now wraps any Exception thrown in source.receive() in a MessagingException. 2008-08-05 21:11:43 +00:00
Mark Fisher
8274dfc428 Removed the @MessageSource method-level annotation and added @Pollable as its replacement. Also added the @ChannelAdapter class-level annotation (refactoring to remove SourceEndpoint). 2008-08-05 20:02:52 +00:00
Mark Fisher
bbd7a12a4e MethodInvokingSource now returns null when the method invocation result is null. 2008-08-05 19:50:14 +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
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
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
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
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
Mark Fisher
77022d0519 DefaultEndpointPoller now implements InitializingBean (to prepare the transactionTemplate), and the poller element parsing now includes the PROPAGATION_ and ISOLATION_ prefixes to properly configure those transaction attributes from the enumerated values defined in the schema. 2008-07-14 20:01:09 +00:00
Mark Fisher
a645841d66 Added support for the <poller/> sub-element within <service-activator/> and <channel-adapter/>. 2008-07-14 19:27:58 +00:00