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
|
69e18fcf95
|
Removed getTrigger() method from MessageEndpoint (avoids a tangle). It is not yet used.
|
2008-07-07 01:43:59 +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
|
c2d5f802c9
|
Moved RouterParser and SplitterParser into 'config' instead of 'router.config' (avoids a tangle).
|
2008-07-07 01:04:10 +00:00 |
|
Mark Fisher
|
0194945ec3
|
ConcurrencyInterceptor implements ChannelRegistryAware instead of MessageBusAware (removes a tangle).
|
2008-07-07 00:59:20 +00:00 |
|
Mark Fisher
|
2c6f496ca7
|
Removed AopContext.currentProxy() call for now.
|
2008-07-06 22:50:55 +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
|
d731f8fb70
|
MessageBus is now an interface. The DefaultMessageBus class is the implementation.
|
2008-07-06 22:11:44 +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
|
9b787a0d5a
|
MessageBus now does a second pass to pick up any MessageChannel that has been provided between the setApplicationContext callback and the ContextRefreshedEvent (INT-270).
|
2008-07-05 22:26:11 +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
|
f479a877b3
|
Removed TargetEndpointParser.
|
2008-07-05 21:16:27 +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
|
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 |
|