Commit Graph

79 Commits

Author SHA1 Message Date
Mark Fisher
add3d6a121 Moved PollingDispatcher from the dispatcher package to the bus package. It depends on the scheduling and channel packages. 2008-08-14 15:28:27 +00:00
Mark Fisher
3e15df93ed MessageDispatcher now extends SubscribableSource. The 'addTarget' and 'removeTarget' methods have been replaced with 'subscribe' and 'unsubscribe' respectively. 2008-08-14 11:53:24 +00:00
Mark Fisher
6cee30bf78 Formatting FtpTarget and removed unused method from ByteArrayMailMessageMapper. 2008-08-13 23:36:41 +00:00
Mark Fisher
f56334f06b Removed TargetEndpoint. 2008-08-12 23:31:48 +00:00
Iwein Fuld
a42f02ec2f 2008-08-11 20:32:52 +00:00
Iwein Fuld
c61ae015f4 added first attempt at FtpTarget, created FTPClientPool to move connection concerns to. 2008-08-11 18:45:29 +00:00
Mark Fisher
6f930ff27b Moved the ID from Message to MessageHeaders. 2008-08-11 15:30:37 +00:00
Mark Fisher
a22ba13809 Removed local .classpath settings 2008-08-09 00:32:44 +00:00
Iwein Fuld
e88776463a tested and fixed onFailure for FtpSource 2008-08-08 14:56:51 +00:00
Jonas Partner
b68fa47fcc Added SubscribabelMailSource and namespace support for pollable and subscribable mail source 2008-08-05 13:47:39 +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
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
Iwein Fuld
48826ec26e put threaded tests and ThreadLocal buffering place for FtpSource, FileSource should work as before, but there are no test for it yet. 2008-08-01 18:55:56 +00:00
Jonas Partner
2b96c536d6 refacotred PollingMailSource and added SubscribableMailSource for use with IMAP idle 2008-08-01 17:29:32 +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
Iwein Fuld
759b5f6d0e cleaning up FtpSourceTests 2008-07-30 17:33:00 +00:00
Iwein Fuld
e61e105232 cleaning up FtpSourceTests 2008-07-30 17:22:07 +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
Iwein Fuld
59a4696d81 polishing testcase 2008-07-30 15:09:45 +00:00
Iwein Fuld
1c55cd53f6 simplified FtpSourceTests (removed checkOrder) 2008-07-30 11:59:48 +00:00
Iwein Fuld
37ca37d2c4 improving FtpSource tests 2008-07-30 10:14:32 +00:00
Mark Fisher
a2d43b1d80 Fixed remoting gateway adapter tests by removing RequestReplyTemplate dependency (replaced with MessageExchangeTemplate). 2008-07-30 03:41:10 +00:00
Mark Fisher
4a808803b9 Updated .classpath file for java mail version 1.4.1. 2008-07-29 23:52:22 +00:00
Mark Fisher
d3ed4a937a Added parser tests for the new MessageListener container attributes on the <jms-gateway/> element (INT-313). 2008-07-29 23:29:38 +00:00
Mark Fisher
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). 2008-07-29 23:08:50 +00:00
Iwein Fuld
3382d0dc92 FtpSource refactoring: Message<File> -> Message<List<File>> 2008-07-29 20:54:42 +00:00
Iwein Fuld
2f2c2fb44d added easymock.classextension dependency 2008-07-29 20:48:18 +00:00
Jonas Partner
df079b1206 specify version of com.sun.mail.imap in template.mf 2008-07-29 11:10:08 +00:00
Jonas Partner
bc53a4ed8e add in idle call 2008-07-29 11:04:03 +00:00
Jonas Partner
bb56220236 updated to use Java Mail 1.4.1 which has IMAP idle support 2008-07-29 10:55:17 +00:00
Jonas Partner
e6302ffff8 part of INT-261 adding polling support for IMAP and POP3 mailboxes based on the strategies implemented in Spring WS 2008-07-29 10:03:51 +00:00
Iwein Fuld
b23e9b43f2 added easymock dependency to org.springframework.integration.adapter 2008-07-25 08:58:20 +00:00
Mark Fisher
f69dc4572c Removed the 'messageCreator' instance (it exists in the parent class: AbstractDirectorySource) and the 'setMessageCreator' method (INT-312). 2008-07-23 12:18:26 +00:00
Mark Fisher
71dd2f2e80 Removed support for <handler-endpoint/> (replaced by <service-activator/>). 2008-07-19 03:23:23 +00:00
Mark Fisher
a3b1c59d10 JmsTarget and JmsSource now check if the provided messageConverter is already a HeaderMappingMessageConverter and if so do not wrap it again (INT-304). 2008-07-18 14:50:21 +00:00
Mark Fisher
2db30ae829 MessageBuilder's copyHeaders(..) method now accepts a Map<String, Object> so there is no need to create the MessageHeaders object. 2008-07-18 13:26:39 +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
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
2afcf4c490 MessageBus is now an interface. The DefaultMessageBus class is the implementation. 2008-07-06 22:09:07 +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
06f4e1d011 Added support for a 'filename-pattern' attribute on <file-source/>. It creates a RegexPatternFilenameFilter instance and sets it on the FileSource (INT-252). 2008-07-05 23:49:23 +00:00
Mark Fisher
b2be3f4d58 Changed 'source-endpoint' to 'channel-adapter'. 2008-07-05 20:04:37 +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
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