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

78 Commits

Author SHA1 Message Date
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
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
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
ca7dc3922e Endpoints now expose a setter for a Poller strategy and no longer implement Lifecycle. 2008-07-14 18:29:07 +00:00
Mark Fisher
92746ebed6 Post interceptors are invoked in the reverse order of pre interceptors 2008-07-09 14:09:25 +00:00
Mark Fisher
dfd7bf551c Refactored interceptors to use EndpointInterceptor interface rather than Advice. 2008-07-09 12:24:16 +00:00
Mark Fisher
f96d4b8d88 Removed DispatcherPolicy (INT-292). 2008-07-08 02:18:41 +00:00
Mark Fisher
47c456e24b Modified test configuration after package removal. 2008-07-07 01:57:04 +00:00
Mark Fisher
47d4093a93 Removed 'bus.interceptor' package for now (avoids a tangle). 2008-07-07 01:50:30 +00:00
Mark Fisher
9409594a1c Removed 'bus.interceptor' package for now (avoids a tangle). 2008-07-07 01:47:34 +00:00
Mark Fisher
c7250f3ea5 Moved PublishSubscribeChannel to 'dispatcher' package since it depends on dispatchers (avoids a tangle). Also moved the PublishSubscribeChannelParser into 'config'. 2008-07-07 01:12:52 +00:00
Mark Fisher
3b6207571f Added more request/reply tests for SimpleMessagingGateway. 2008-07-06 22:40:16 +00:00
Mark Fisher
99af66481d MessageHeader is now an interface. The DefaultMessageHeader class is the implementation used by GenericMessage (INT-288). 2008-07-06 22:34:51 +00:00
Mark Fisher
9c49063a3c MessagingGatewaySupport is now MessageBusAware. Added request/reply tests for SimpleMessagingGateway. 2008-07-06 22:17:12 +00:00
Mark Fisher
2afcf4c490 MessageBus is now an interface. The DefaultMessageBus class is the implementation. 2008-07-06 22:09:07 +00:00
Mark Fisher
bfd3d5392b Using direct-channel for input and split. 2008-07-06 20:56:55 +00:00
Mark Fisher
5dc6488de0 The <aggregator/> element now creates a HandlerEndpoint instance. It now requires "input-channel" and "output-channel" (and it no longer accepts "default-reply-channel"). It also no longer accepts a <completion-strategy/> sub-element. Instead, for a pojo-based adapter, add the "completion-strategy-method" attribute along with the "completion-strategy" reference (INT-285). 2008-07-06 20:35:36 +00:00
Mark Fisher
b7f31fcbf0 The <router/> element now creates its own endpoint (i.e. it is no longer necessary to create a <handler-endpoint/> as well) (INT-284). 2008-07-06 18:08:31 +00:00
Mark Fisher
a83e39b6ce The <splitter/> element now creates its own endpoint (i.e. it is no longer necessary to create a <handler-endpoint/> as well) (INT-283). Also, the <handler-endpoint/>'s "handler" attribute has been replaced with "ref" to be more consistent with other spring configuration options (e.g. defining jms-listeners with the JMS namespace support). 2008-07-06 17:36:42 +00:00
Mark Fisher
1b90086e4e Endpoints now recognize an EndpointVisitor in the message payload. The EndpointPoller is now an implementation of EndpointVisitor (removed PollCommand). 2008-07-06 03:09:56 +00:00
Mark Fisher
5d25b93461 ChannelFactory now accepts the channel name (INT-280). 2008-07-05 22:59:25 +00:00
Mark Fisher
248209bf00 Annotation-based aggregator methods now use the output channel specified in a class-level @MessageEndpoint annotation. The 'defaultReplyChannel' property is no longer available on the @Aggregator annotation itself (INT-274). 2008-07-05 21:57:25 +00:00
Mark Fisher
5a40f17826 Both "source-endpoint" and "target-endpoint" elements are now configured as <channel-adapter/>. That element requires exactly one of "source" or "target" and optionally accepts a "method" attribute for creating either a MethodInvokingSource or a MethodInvokingTarget (INT-277). 2008-07-05 20:02:12 +00:00
Mark Fisher
6cb6347b82 Endpoint now throws MessageRejectedException when a MessageSelector rejects a Message. 2008-07-05 18:39:11 +00:00
Mark Fisher
f6de774110 Now invokes the transformer in 'preSend' instead of 'postSend'. 2008-07-05 16:56:05 +00:00
Jonas Partner
e1dca0ff9f ChannelInterceptor which allows transformation on send or receive from a channel 2008-07-05 13:42:32 +00:00
Mark Fisher
71da892bcb Removed the Subscription class. 2008-07-04 22:39:18 +00:00
Mark Fisher
96b22fd01b Removing usage of the Subscription object, and resolved issue with 'auto-create' channels for SourceEndpoints (INT-235). 2008-07-04 21:31:25 +00:00
Mark Fisher
0aa00b969b Major refactoring of endpoint subscription, scheduling, and activation. This includes significant changes to the dispatcher implementations and the addition of endpoint "triggers" to drive polling and dispatching of messages. Also introduces an explicit PublishSubscribeChannel implementation and thereby removes support for the "publish-subscribe" attribute from channel elements in the namespace. 2008-07-04 18:48:33 +00:00
Mark Fisher
25bcd05293 Added tests for SimpleMessagingGateway. 2008-07-03 17:47:07 +00:00
Mark Fisher
7d8a6c0f84 Removed unnecessary lifecycle calls. 2008-07-03 16:26:49 +00:00
Mark Fisher
d998095421 Removed 'maxMessagesPerTask' and 'receiveTimeout' properties from DispatcherPolicy and added those same properties to PollingDispatcherTask. The MessageDispatcher interface now extends the MessageTarget interface. Therefore, the 'dispatch(Message)' method has been replaced with 'send(Message)'. 2008-07-02 22:56:00 +00:00
Jonas Partner
7cefe22b96 changed MethodInvoking Soure and Targt to take a string via a a property methodName (fix for INT-272) 2008-07-02 19:29:25 +00:00
Mark Fisher
ab858ee247 Refactored MessagingTaskScheduler to support cancellation and renamed 'TaskScheduler'. 2008-07-02 18:42:33 +00:00
Mark Fisher
85133ae370 Added tests for transaction propagation. 2008-07-02 01:04:25 +00:00
Mark Fisher
570cee8f9b Refactoring lifecycle code for endpoint hierarchy. 2008-07-01 23:01:42 +00:00
Mark Fisher
9dad71117b Added TransactionInterceptorTests. 2008-07-01 22:04:17 +00:00
Mark Fisher
f3f7daa201 Replaced ConcurrentTarget and the <concurrency/> element with ConcurrencyInterceptor. 2008-07-01 19:38:55 +00:00
Mark Fisher
117973082e Renamed 'advice-chain' element to 'interceptors'. 2008-07-01 14:01:37 +00:00