6cee30bf78
Formatting FtpTarget and removed unused method from ByteArrayMailMessageMapper.
Mark Fisher
2008-08-13 23:36:41 +00:00
0d49689821
Extracted message-to-args mapping logic from AbstractMessageHandler to MethodArgumentMessageMapper. Defined a separate abstract method in AbstractMessageHandler for post-processing a return value that is already a Message. DefaultMethodInvoker catches an IllegalArgumentException in case the Method instance no longer matches after a Proxy and "resets" the correct Method if it can be determined from the 'methodName' property. Replaced AnnotationMethodTransformerAdapter with TransformerMessageHandler.
Mark Fisher
2008-08-13 23:31:18 +00:00
0f93cab8cc
Factored out DefaultEndpoint's generic logic to AbstractEndpoint.
Mark Fisher
2008-08-13 18:10:38 +00:00
51f8beffba
Removed AbstractEndpoint.
Mark Fisher
2008-08-13 17:12:21 +00:00
ee35a37f50
Renamed AbstractHandlerEndpointParser to AbstractMessageEndpointParser.
Mark Fisher
2008-08-13 16:50:25 +00:00
9669467f98
Renamed SimpleEndpoint to DefaultEndpoint.
Mark Fisher
2008-08-13 16:31:45 +00:00
616eba8701
Added more tests.
Mark Fisher
2008-08-13 16:17:11 +00:00
e16dce8aba
Removed the HandlerEndpoint (now replaced by SimpleEndpoint).
Mark Fisher
2008-08-13 15:49:24 +00:00
a3f6254856
AbstractHandlerEndpointParser's default endpoint type is now SimpleEndpoint instead of HandlerEndpoint. The latter will be removed shortly.
Mark Fisher
2008-08-13 15:03:45 +00:00
5c9ac92f6b
Removed the registerHandler() method from MessageBus.
Mark Fisher
2008-08-13 01:16:32 +00:00
f56334f06b
Removed TargetEndpoint.
Mark Fisher
2008-08-12 23:31:48 +00:00
744db9e5a1
Added namespace support for the WireTap (INT-323).
Mark Fisher
2008-08-12 22:49:27 +00:00
1e8fa31e9d
WireTap now accepts any MessageTarget for sending intercepted Messages instead of requiring a MessageChannel.
Mark Fisher
2008-08-12 21:45:25 +00:00
d212fb51b8
MethodInvokingSource and MethodInvokingTarget both accept a 'method' parameter, so that when the actual Method is known (e.g. annotation-driven post-processing), it can be set directly. The 'methodName' is still supported, because it is necessary for XML-based configuration (INT-334).
Mark Fisher
2008-08-12 21:13:58 +00:00
ead292fd1f
The @MessageTarget annotation is now used with @ChannelAdapter (like @PollableSource) instead of @MessageEndpoint.
Mark Fisher
2008-08-12 20:49:55 +00:00
d0581e881f
EndpointInterceptor postHandle now accepts the replyMessage only. InterceptingMessageHandler has been renamed MessageHandlerDecorator. Either the decorator or the interceptor's aroundHandle method may be removed since they are redundant.
Mark Fisher
2008-08-12 17:32:51 +00:00
ac770ce178
MessageTarget is now sufficient for the replyTarget (no longer requires MessageChannel), so for example it can now support the temporary returnAddress set by the MessageExchangeTemplate. Also, the 'outputChannel' is given precedence while 'returnAddress' is used as a fallback. This is consistent with the other Message-handling endpoint types (INT-332, INT-333).
Mark Fisher
2008-08-12 11:52:25 +00:00
56f5a9374c
MethodInvokingTarget now extends AbstractMessageHandler instead of AbstractMessageHandlerAdapter. SplitterMessageHandlerCreator no longer requires configuration of the "outputChannel" property.
Mark Fisher
2008-08-12 11:30:18 +00:00
178c438159
Refactored RouterMessageHandlerAdapter (now RouterMessageHandler). Router endpoints are now SimpleEndpoint instances.
Mark Fisher
2008-08-12 03:44:23 +00:00
f91ec6f48f
Moved aggregator and splitter classes into separate packages (instead of 'router').
Mark Fisher
2008-08-12 00:59:15 +00:00
c2e6be171d
SplitterMessageHandler replaces SplitterMessageHandlerAdapter.
Mark Fisher
2008-08-12 00:22:02 +00:00
c63f65f256
Preventing copy of ID or timestamp header attributes.
Mark Fisher
2008-08-12 00:01:20 +00:00
3d4f32de2d
Added method validation and added check for Message-typed parameter.
Mark Fisher
2008-08-11 20:45:59 +00:00
df0653f8cd
Added new SplitterMessageHandler and refactored SplitterParser to use that handler implementation.
Mark Fisher
2008-08-11 20:25:44 +00:00
215e10a6eb
Added test timeouts for Message reception.
Mark Fisher
2008-08-11 20:16:55 +00:00
8732ac26b4
Updated service-activator to use new SimpleEndpoint and DefaultMessageHandler. Modified EndpointInterceptor for preHandle/aroundHandle/postHandle with access-to and return-values-for the request/reply Messages.
Mark Fisher
2008-08-11 19:39:42 +00:00
c61ae015f4
added first attempt at FtpTarget, created FTPClientPool to move connection concerns to.
Iwein Fuld
2008-08-11 18:45:29 +00:00
f2761d8c44
Removed the getMessageExchangeTemplate() method from the MessageEndpoint interface.
Mark Fisher
2008-08-11 15:41:09 +00:00
6f930ff27b
Moved the ID from Message to MessageHeaders.
Mark Fisher
2008-08-11 15:30:37 +00:00
e6c63cfb0b
SimpleEndpoint provides the ChannelRegistry reference to its handler if that handler implements ChannelRegistryAware.
Mark Fisher
2008-08-11 14:09:57 +00:00
a22ba13809
Removed local .classpath settings
Mark Fisher
2008-08-09 00:32:44 +00:00
9a1714fae4
Added new SimpleEndpoint implementation. This is the first step of a gradual migration process (i.e. it is not yet in use). Also added the MessageEndpointReplyException.
Mark Fisher
2008-08-09 00:26:41 +00:00
a7acc62371
Added CompositeMessage and added the 'nextTarget' header to MessageHeaders (and the corresponding methods in MessageBuilder).
Mark Fisher
2008-08-08 21:30:49 +00:00
e88776463a
tested and fixed onFailure for FtpSource
Iwein Fuld
2008-08-08 14:56:51 +00:00
fbb5123e8e
tests for StringSourceFactory
Jonas Partner
2008-08-07 15:04:33 +00:00
99d26a5b04
fix for INT-324
Jonas Partner
2008-08-07 14:48:32 +00:00
52f61b3d88
The PollingDispatcher's default receiveTimeout is now -1 for indefinite blocking.
Mark Fisher
2008-08-06 19:43:24 +00:00
528f5e6341
The @Polled annotation has been renamed @Poller (it no longer applies directly to a method).
Mark Fisher
2008-08-05 21:30:44 +00:00
1e82a8d568
Removed SourceEndpoint. Also, MessageExchangeTemplate now wraps any Exception thrown in source.receive() in a MessagingException.
Mark Fisher
2008-08-05 21:11:43 +00:00
8274dfc428
Removed the @MessageSource method-level annotation and added @Pollable as its replacement. Also added the @ChannelAdapter class-level annotation (refactoring to remove SourceEndpoint).
Mark Fisher
2008-08-05 20:02:52 +00:00
bbd7a12a4e
MethodInvokingSource now returns null when the method invocation result is null.
Mark Fisher
2008-08-05 19:50:14 +00:00
0662b3edee
Changed number of requests for multipleMessagesWithResponseCorrelator test.
Mark Fisher
2008-08-05 17:04:05 +00:00
82d353230b
Increased test latch wait time.
Mark Fisher
2008-08-05 16:45:37 +00:00
a0b603b0fe
The <poller/> element now accepts the "initial-delay" and "fixed-rate" (boolean) attributes (INT-326).
Mark Fisher
2008-08-05 16:37:32 +00:00
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).
Mark Fisher
2008-08-05 15:31:22 +00:00
b68fa47fcc
Added SubscribabelMailSource and namespace support for pollable and subscribable mail source
Jonas Partner
2008-08-05 13:47:39 +00:00
d929797867
Setting inputChannelName instead of source when <poller/> is not provided so that auto-create works (it does not apply with <poller/>).
Mark Fisher
2008-08-05 03:04:21 +00:00
de207c9bda
PollingDispatchers are configured from the <poller/> element. The <schedule/> element has been removed. Instead the 'period' attribute is now available on <poller/>.
Mark Fisher
2008-08-05 02:52:52 +00:00
9f3e7d3d24
Removed EndpointTrigger, EndpointPoller, and EndpointVisitor. MessageBus now schedules PollingDispatchers for endpoints.
Mark Fisher
2008-08-05 01:59:35 +00:00
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.
Mark Fisher
2008-08-02 16:28:17 +00:00
e9050a8f82
Cosmetic changes
Marius Bogoevici
2008-08-02 15:32:06 +00:00
cfac014122
Updated channel-adapter configuration in quoteDemo and temperatureConversion.xml (WS demo) after the channel-adapter refactoring (The <channel-adapter/> element no longer accepts a "channel" reference. Instead, it creates a channel itself).
Mark Fisher
2008-08-02 00:19:42 +00:00
4ebfc051d5
Modified oddEvenDemo configuration to use a MethodInvokingSource bean definition.
Mark Fisher
2008-08-02 00:09:39 +00:00
66835cb5ff
Removed SimpleTaskScheduler.
Mark Fisher
2008-08-01 23:52:16 +00:00
4b42ea9de4
First cut at refactoring TaskScheduler: adding SPI interface and ScheduledExecutorService-based implementation.
Marius Bogoevici
2008-08-01 23:33:04 +00:00
98633cec5d
updated EndpointInterceptorParser.java
Mark Fisher
2008-08-01 23:13:20 +00:00
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/>).
Mark Fisher
2008-08-01 23:11:56 +00:00
48826ec26e
put threaded tests and ThreadLocal buffering place for FtpSource, FileSource should work as before, but there are no test for it yet.
Iwein Fuld
2008-08-01 18:55:56 +00:00
6f48cb218c
cleaned up comment
Iwein Fuld
2008-08-01 18:03:36 +00:00
2b96c536d6
refacotred PollingMailSource and added SubscribableMailSource for use with IMAP idle
Jonas Partner
2008-08-01 17:29:32 +00:00
0c38b88ad3
EndpointPoller now uses the MessageEndpoint's MessageExchangeTemplate. This allows poller transactions to work as configured on the endpoint's <poller/> sub-element.
Mark Fisher
2008-08-01 12:23:05 +00:00
d8375cd3a6
The targetMock expectation now returns true instead of null in 'multipleTargetsPartialTimeout()' test (avoids delayed NPE).
Mark Fisher
2008-07-31 13:52:35 +00:00
3a99b96966
Removed ChannelPublisher. MessageExchangeTemplate is sufficient.
Mark Fisher
2008-07-30 23:32:27 +00:00
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.
Mark Fisher
2008-07-30 20:48:00 +00:00
759b5f6d0e
cleaning up FtpSourceTests
Iwein Fuld
2008-07-30 17:33:00 +00:00
e61e105232
cleaning up FtpSourceTests
Iwein Fuld
2008-07-30 17:22:07 +00:00
35b77dabaf
Removed setName from the MessageEndpoint interface, and the annotation post-processors now return AbstractEndpoint instead of MessageEndpoint.
Mark Fisher
2008-07-30 16:45:00 +00:00
b9bb70b634
Added support for 'apply-sequence' on <publish-subscribe-channel/>. The BroadcastingDispatcher has the 'applySequence' property (INT-321).
Mark Fisher
2008-07-30 16:02:47 +00:00
f30c1b73b2
Simplified AbstractHandlerEndpointParser and renamed AbstractEndpoint's setMessageSelector to setSelector (for consistency with setSource, setTarget, etc).
Mark Fisher
2008-07-30 14:06:37 +00:00
a2d43b1d80
Fixed remoting gateway adapter tests by removing RequestReplyTemplate dependency (replaced with MessageExchangeTemplate).
Mark Fisher
2008-07-30 03:41:10 +00:00
60cdfe4ffe
Replacing RequestReplyTemplate with MessageExchangeTemplate. The ReplyMessageCorrelator delegation is now within the SimpleMessagingGateway.
Mark Fisher
2008-07-30 03:19:57 +00:00
a8075554ed
Removed poll() method from AbstractEndpoint.
Mark Fisher
2008-07-30 01:37:21 +00:00
4a808803b9
Updated .classpath file for java mail version 1.4.1.
Mark Fisher
2008-07-29 23:52:22 +00:00
d3ed4a937a
Added parser tests for the new MessageListener container attributes on the <jms-gateway/> element (INT-313).
Mark Fisher
2008-07-29 23:29:38 +00:00
9a9e601451
Added the following MessageListener container configuration attributes to the jms-gateway element: concurrent-consumers, max-concurrent-consumers, max-messages-per-task, and idle-task-execution-limit (INT-313).
Mark Fisher
2008-07-29 23:08:50 +00:00
83399a95cb
Renamed the 'defaultReplyChannel' property to 'outputChannel' (and renamed the corresponding xml attributes) for the aggregator and resequencer.
Mark Fisher
2008-07-29 22:51:33 +00:00
07efae79e6
Added HeaderTransformer strategy interface and HeaderTransformingMessageHandler adapter (INT-307).
Mark Fisher
2008-07-29 21:19:55 +00:00
91226f8a34
MessageEndpoint now defines getSource() and getTarget() instead of getInputChannel() and getOutputChannel(). EndpointPoller now uses a MessageExchangeTemplate and MessageEndpoint no longer defines poll().
Mark Fisher
2008-07-29 19:32:14 +00:00
df079b1206
specify version of com.sun.mail.imap in template.mf
Jonas Partner
2008-07-29 11:10:08 +00:00
bc53a4ed8e
add in idle call
Jonas Partner
2008-07-29 11:04:03 +00:00
bb56220236
updated to use Java Mail 1.4.1 which has IMAP idle support
Jonas Partner
2008-07-29 10:55:17 +00:00
e6302ffff8
part of INT-261 adding polling support for IMAP and POP3 mailboxes based on the strategies implemented in Spring WS
Jonas Partner
2008-07-29 10:03:51 +00:00
57117efe41
Removed EndpointPolicy interface.
Mark Fisher
2008-07-29 02:32:39 +00:00
654a626419
Added MessageExchangeTemplate, AsyncMessageExchangeTemplate, and AsyncMessage. Removed Poller, SimplePoller, DefaultEndpointPoller, SourceInvoker, and TargetInvoker.
Mark Fisher
2008-07-28 23:42:50 +00:00
0ecda21ea2
HandlerEndpoint now accepts any MessageTarget as a 'returnAddress' rather than expecting a channel or channel-name.
Mark Fisher
2008-07-28 18:26:59 +00:00
f69dc4572c
Removed the 'messageCreator' instance (it exists in the parent class: AbstractDirectorySource) and the 'setMessageCreator' method (INT-312).
Mark Fisher
2008-07-23 12:18:26 +00:00
a85f556bb8
Replaced <handler-endpoint/> with <service-activator/> in demos.
Mark Fisher
2008-07-19 03:31:11 +00:00
71dd2f2e80
Removed support for <handler-endpoint/> (replaced by <service-activator/>).
Mark Fisher
2008-07-19 03:23:23 +00:00
fcc5d56f81
Removed ReplyHandler.
Mark Fisher
2008-07-19 03:09:23 +00:00
0aa8aeb129
Refactored SimpleDispatcher and added test cases in SimpleDispatcherTests. Also removed MessageHandlerNotRunningException.
Mark Fisher
2008-07-18 23:00:03 +00:00
ce88e75725
Moved AbstractPayloadTransfomerParser into 'src/main' (instead of 'src/test').
Mark Fisher
2008-07-18 20:34:45 +00:00
Mark Fisher