Mark Fisher
9f2b0af8c3
Migrated the stream-based adapters from the "adapters" module to "org.springframework.integration.stream" (INT-375).
2008-09-17 20:32:47 +00:00
Mark Fisher
f7ea3f765d
Removed 'event' code from the 'org.springframework.integration.adapter' module (INT-375).
2008-09-17 18:13:16 +00:00
Iwein Fuld
a4daf1c0f7
Added noOp check to QueuedFtpClientPool
...
removed tracing from PollableFileSource
2008-09-14 12:31:16 +00:00
Iwein Fuld
0f9dc8c750
Complete - task 6: Create PollableFileSource
...
Last review done by Mark and Arjen, modification time concern pushed out.
Added parameter to MessageDeliveryAware
2008-09-11 13:40:12 +00:00
Mark Fisher
2a2d076b36
Renamed MessageExchangeTemplate to MessageChannelTemplate.
2008-09-09 10:36:29 +00:00
Mark Fisher
35e744e60a
Added AbstractMessageConsumingEndpoint. MessageDispatchers now expect MessageConsumer instances as subscribers, and the MessageEndpoint no longer has a send() method or a getSource() method. All consumer endpoints now use 'inputChannel' as the property (instead of source). The MessageBus is less involved in endpoint activation now, since endpoints that need to poll a channel can create, configure, and schedule their own poller.
2008-09-07 21:04:50 +00:00
Mark Fisher
15f9875b5b
Refactored PollingDispatcher into separate ChannelPoller and SourcePoller implementations with an AbstractPoller base class.
2008-09-07 15:23:17 +00:00
Mark Fisher
f0079d97f2
Updated test configuration for stdout and stderr Channel Adapter parsing.
2008-09-07 01:51:18 +00:00
Mark Fisher
673d7d250b
MessageEndpoint no longer extends the MessageTarget interface.
2008-09-07 01:48:34 +00:00
Mark Fisher
b47d81ff16
MessageChannels no longer implement MessageTarget, and MessageEndpoints that send a reply have a setOutputChannel() method instead of setTarget().
2008-09-05 16:36:13 +00:00
Iwein Fuld
69c4441dde
Create PollableFileSource
...
This version waits until the next whole second before picking up files. This behavior should be made optional later.
2008-09-04 17:29:54 +00:00
Iwein Fuld
82b92ecf05
Incomplete: Create PollableFileSource (this is the first step to make Backlog obsolete)
2008-09-03 15:40:59 +00:00
Mark Fisher
788b2364ec
The <channel/> element is now used for creating all Point-to-Point channel types. It accepts a queue sub-element (options are: <queue/>, <priority-queue/>, or <rendezvous-queue/>). If no queue sub-element is provided, the channel type will be a DirectChannel.
2008-09-01 22:50:56 +00:00
Iwein Fuld
a27ae5726e
INT-356: Changed namespace parsing to resolve incompatible MessageCreator problem. type attribute on ftpsource no longer supported.
2008-09-01 17:41:19 +00:00
Iwein Fuld
12a0142d7b
Complete: Test Backlog concurrency
...
Incomplete: Improve FileSource. Added comparator constructor arg. Still need namespace cleanup
2008-09-01 11:46:14 +00:00
Iwein Fuld
b009bb137c
Backlog concurrency improvements (and tests)
2008-08-30 13:55:16 +00:00
Mark Fisher
a162156b2a
typo
2008-08-25 12:15:30 +00:00
Iwein Fuld
8559f2f74b
Incomplete: Improve FileSource
...
- refactored Backlog to be more robust (still missing concurrent testcases)
- refactored FileInfo into FileSnapshot (to remove need for maps in backlog)
- refactored testcases and AbstractDirectorySource accordingly
2008-08-24 13:24:15 +00:00
Mark Fisher
3b256d9e81
Renamed 'setMaxMessagesPerPayload()' method to 'setMaxFilesPerMessage()'.
2008-08-21 13:15:46 +00:00
Mark Fisher
ce87fef7ac
Renamed JmsAttributeKeys to JmsHeaders and MailAttributeKeys to MailHeaders. JMS Headers are now propagated properly by the JmsGateway (INT-290).
2008-08-19 17:32:48 +00:00
Mark Fisher
2ba1fe0842
AbstractMailHeaderMapper correctly handles FROM and REPLY_TO as String values rather than Arrrays (INT-345).
2008-08-19 12:44:55 +00:00
Mark Fisher
4834c8a1b4
TextMailMessageMapper invokes the toString method on any Message payload rather than requiring a StringMessage. Also, removed the obsolete toMessage() method.
2008-08-18 18:48:05 +00:00
Mark Fisher
30fd7decc8
Modified the 'onFailure' method signature in MessageDeliveryAware so that any Exception can be passed along with a separate Message parameter instead of always expecting a MessagingException.
2008-08-18 18:40:39 +00:00
Iwein Fuld
2977f4f61b
added timeout to FtpSourceTests
2008-08-18 13:28:12 +00:00
Mark Fisher
9b85225675
Channel Adapters are now endpoints, but if no "channel" attribute if provided for a <channel-adapter/> element, a DirectChannel will be created automatically. The <poller/> sub-element now belongs within the <channel-adapter/> (not the consumer endpoint downstream). This enables support for multiple Channel Adapters to share a MessageChannel. Also, the @Poller annotation belongs at class-level along with @ChannelAdapter if a @Pollable method is being adapted via MethodInvokingSource.
2008-08-17 22:37:35 +00:00
Iwein Fuld
c48fa5a361
missed @Ignore
2008-08-17 05:52:25 +00:00
Iwein Fuld
5a70203349
Finishing up INT-293, INT-154. Parametrized DefaultMessageMapper, refactored FtpSource to use a pool, added namespace support for FtpTarget.
2008-08-17 05:47:46 +00:00
Iwein Fuld
d6aed95948
Finishing up INT-293, INT-154. Parametrized DefaultMessageMapper, refactored FtpSource to use a pool, added namespace support for FtpTarget.
2008-08-17 05:37:03 +00:00
Iwein Fuld
32f4722ee4
FtpTargetTest and pool improvement
2008-08-15 13:25:10 +00:00
Iwein Fuld
08252fdbaf
... and FtpTarget should depend on that interface
2008-08-14 20:23:23 +00:00
Iwein Fuld
b4ba382404
added missing interface
2008-08-14 20:16:56 +00:00
Mark Fisher
4ae5e7d0ff
Removed FTPClientPool for now since the QueuedFTPClientPool was expecting an interface.
2008-08-14 19:53:36 +00:00
Iwein Fuld
890b09c0c5
FTPClientPool improvements and javadoc.
2008-08-14 19:03:04 +00:00
Mark Fisher
824fff8381
Moved PollingDispatcher back into the 'dispatcher' package now that the cycle (with 'channel' and 'scheduling') has been removed.
2008-08-14 15:53:21 +00:00
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
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
