Jonas Partner
e1dca0ff9f
ChannelInterceptor which allows transformation on send or receive from a channel
2008-07-05 13:42:32 +00:00
Mark Fisher
bd5d71120f
Added CallerRunsPolicy and threadNamePrefix for default MessageBus taskScheduler and ConcurrencyInterceptor.
2008-07-04 23:32:27 +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
acbde74691
Changed default receiveTimeout to 5000 ms (was -1 for indefinite blocking).
2008-07-03 16:26:23 +00:00
Mark Fisher
aa1629b7cc
Add cancellation of tasks in the stop() method.
2008-07-03 15:50:29 +00:00
Jonas Partner
27ac25ed33
Namespace support for endpoint interceptor security
2008-07-03 14:21:08 +00:00
Mark Fisher
c59bbe767a
Changed instance variable name to 'methodName' to match the 'setMethodName' method definition.
2008-07-02 23:31:34 +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
af8ae9780b
Setting correlationId (if not already present) when processing aggregated Messages.
2008-07-02 03:28:16 +00:00
Mark Fisher
65ba407e84
Refactored MessageBus to accept a MessagingTaskScheduler instead of setting the ScheduledExecutorService directly. The SimpleMessagingTaskScheduler does not shutdown the executor until 'destroy' is called. The 'stop' call only prevents task submission until the next invocation of 'start' on the scheduler.
2008-07-02 02:37:13 +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
d0fe157d0a
Added EndpointInterceptorParser helper class to improve organization of EndpointInterceptor parsing logic.
2008-07-01 20:47:53 +00:00
Mark Fisher
71c35ee513
Removed parsing instructions for deleted properties (concurrencyPolicy and errorHandler).
2008-07-01 19:49:48 +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
Mark Fisher
486df85a68
Added namespace support for Endpoint interceptors including TransactionInterceptor (INT-85).
2008-07-01 13:59:02 +00:00
Mark Fisher
908966d975
Renamed Target to MessageTarget.
2008-06-30 23:23:04 +00:00
Mark Fisher
504b101213
Increased timeout for test method.
2008-06-30 23:05:58 +00:00
Mark Fisher
5235537c80
Renamed Source to MessageSource.
2008-06-30 22:57:23 +00:00
Mark Fisher
07b2179baa
Added support for interceptors on MessageEndpoints.
2008-06-30 22:26:04 +00:00
Mark Fisher
c18ec83cbf
Added 'waitForTasksToCompleteOnShutdown' property to SimpleMessagingTaskScheduler with a default value of 'true' (INT-268).
2008-06-25 21:20:09 +00:00
Jonas Partner
9ed5cc6a61
removed security references
2008-06-25 17:30:12 +00:00
Mark Fisher
00436b9071
Added namespace support for creating a MessageSelectorChain (INT-227).
2008-06-24 21:11:30 +00:00
Mark Fisher
e24fe02cf0
Added MessageStoringInterceptor (INT-264).
2008-06-24 15:26:24 +00:00
Marius Bogoevici
490a3d9951
Adds support for an <interceptor/> sub-element of <message-bus/>
2008-06-22 17:36:45 +00:00
Jonas Partner
f3d2c23069
increased timeout on failing tests
2008-06-20 15:16:19 +00:00
Marius Bogoevici
deff988c74
Increased timeouts.
2008-06-20 04:39:29 +00:00
Marius Bogoevici
3f584ea2b7
Adds a MessageBusInterceptor
2008-06-17 04:52:23 +00:00
Marius Bogoevici
4e523b00ba
Adding a specific test demonstrating the usage of <message-bus channel-factory="..."/> and <channel-factory .../>
2008-06-16 14:13:41 +00:00
Marius Bogoevici
1d7d9046ae
http://jira.springframework.org/browse/INT-253
...
Reply-channel on a <gateway/> is now optional. If absent, a temporary RendezvousChannel will be created for this particular invocation (default bevaviour of the underlying RequestReplyTemplate).
Also, a small fix for the corner case when a method like void doNothing() is called. In this case, nothing happens.
2008-06-09 20:27:55 +00:00
Mark Fisher
0300168c82
Adding support for secured channels.
2008-06-05 23:57:49 +00:00
Mark Fisher
722b9c4f1c
Added initial support for the MessageTransformer strategy and the @Transformer method-level annotation. Also added the PayloadTransformerAdapter implementation (INT-6).
2008-06-05 04:48:03 +00:00
Mark Fisher
bd39e93257
Formatting.
2008-06-04 11:00:51 +00:00
Ben Hale
1db7d245eb
Upgrade for spring-build. Removal of fixed manifests in lieu of bundlor templates
2008-06-04 10:05:57 +00:00
Marius Bogoevici
0f64b81180
Fixes INT-24 (resequencer) by adding a <resequencer/> namespace element.
2008-06-04 02:34:14 +00:00
Marius Bogoevici
eaeaa14a41
Partial fix for INT-24 (add resequencer). A namespace element needs also to be created.
2008-06-03 03:42:57 +00:00
Mark Fisher
aab138cb10
MessageBus now recognizes MessagingGateway implementations within the ApplicationContext, and if a gateway also implements Lifecycle (e.g. JmsGateway), that lifecycle can now be managed by the MessageBus (INT-237).
2008-06-02 18:54:51 +00:00
Mark Fisher
6fe0e44331
MessagingAnnotationPostProcessor avoids null target class (INT-239).
2008-06-02 18:07:49 +00:00
Mark Fisher
c28a4bc448
Intercepting toString method invocation for gateway proxy (related to INT-239).
2008-06-02 17:41:48 +00:00
Marius Bogoevici
af259f40f9
fixes INT-236 - aggregation continues after completion
2008-06-02 04:00:44 +00:00
Mark Fisher
66147a71ab
Now propagating the 'correlationId' on the aggregation result Message's header.
2008-05-31 14:34:49 +00:00
Mark Fisher
05524a330a
Refactored MessageEndpointAnnotationPostProcessor to MessagingAnnotationPostProcessor which delegates to HandlerAnnotationPostProcessor, SourceAnnotationPostProcessor, and TargetAnnotationPostProcessor (work related to INT-194 and INT-195).
2008-05-30 22:18:07 +00:00
