Commit Graph

392 Commits

Author SHA1 Message Date
Mark Fisher
8ea24913b5 Added SimpleHeaderEnricherParser. 2008-09-26 20:47:42 +00:00
Mark Fisher
a055f0d97d Added HeaderEnricher. 2008-09-26 20:42:25 +00:00
Mark Fisher
f2b7353165 Added namespace support for FileToStringTransformer and FileToByteArrayTransformer. 2008-09-26 18:27:22 +00:00
Mark Fisher
959b906f4e AbstractTransformerParser now creates the actual endpoint rather than requiring a "ref" to an object that implements Transformer. Therefore the element being parsed must provide 'input-channel' and 'output-channel'. 2008-09-26 17:42:11 +00:00
Mark Fisher
9ee921ed7c Removed the PollableSource interface, and migrated the 'receive()' method to MessageSource. 2008-09-26 16:31:26 +00:00
Mark Fisher
40938a36f3 MessageMapper is parameterized. 2008-09-25 21:31:27 +00:00
Mark Fisher
b0a00c7c0d Refactored SimpleMessagingGateway to include a base AbstractMessagingGateway with abstract methods for mapping messages to and from Objects. SimpleMessagingGateway delegates to a MessageMapper instance or uses DefaultMessageMapper. 2008-09-25 21:18:01 +00:00
Mark Fisher
8b24cd7d6b MessageMapper now defines toMessage() and fromMessage() methods, and the MessageCreator has been removed. 2008-09-25 18:27:52 +00:00
Mark Fisher
d30fe71dc2 MessagePublishingInterceptor uses MessageBuilder instead of MessageCreator. 2008-09-25 15:12:53 +00:00
Mark Fisher
51eb976236 Removed MailMessageMappers. MailMessageSendingConsumer now handles any MailMessage payload or byte array payload. For all other payload types, it calls 'toString' to generate the Mail text. 2008-09-25 14:40:48 +00:00
Marius Bogoevici
3e675ca2e5 Solves a race condition between start() on the class and run() on the internal SchedulerTask. 2008-09-25 04:56:26 +00:00
Mark Fisher
60e245f5a6 BroadcastingDispatcher tries to send to all consumers even if one "Selective Consumer" throws a MessageRejectedException (consistent with SimpleDispatcher's behavior). 2008-09-25 03:52:35 +00:00
Mark Fisher
91c094a174 Added namespace support for the <filter/> element. 2008-09-25 00:20:36 +00:00
Mark Fisher
784c732389 Added MethodInvokingSelector. 2008-09-24 23:44:33 +00:00
Mark Fisher
2feb20e022 MessageMappingMethodInvoker now uses Assert instead of throwing ConfigurationException if the method does not accept any arguments. 2008-09-24 23:37:21 +00:00
Mark Fisher
b0fc5da6a2 The <poller/> element now accepts the "interval" attribute for an IntervalTrigger instead of "period". 2008-09-24 19:40:38 +00:00
Mark Fisher
506636caf0 The 'lifecycleLock' is now acquired within the isRunning() method. 2008-09-24 18:47:57 +00:00
Mark Fisher
d2bddbbbfa Removed Schedule, PollingSchedule, and CronSchedule. These have been replaced by Trigger, IntervalTrigger, and CronTrigger. 2008-09-24 18:36:36 +00:00
Mark Fisher
ee7a8d0725 Replacing Schedule with Trigger. 2008-09-24 18:29:23 +00:00
Mark Fisher
05cfa42426 Added context.stop() calls at end of test methods. 2008-09-24 17:29:27 +00:00
Mark Fisher
26834f88f8 Iteration on a SynchronizedSet must be manually synchronized (default mutex is the collection instance itself). 2008-09-24 17:28:47 +00:00
Mark Fisher
9e1e1199ee Refactored TaskScheduler to use the new Trigger interface. Also added the SimpleTaskScheduler implementation. 2008-09-24 16:29:14 +00:00
Mark Fisher
98b32a9516 Adding Trigger interface and the IntervalTrigger and CronTrigger implementations. 2008-09-24 14:59:32 +00:00
Mark Fisher
de10530387 Moved MessageChannelTemplate and AsyncMessageChannelTemplate to the 'channel' package (was in 'message'). 2008-09-24 13:50:31 +00:00
Mark Fisher
4664ef5f81 The <inbound-channel-adapter/> and <outbound-channel-adapter/> elements now expect the "ref" attribute (instead of "source" for inbound and "target" for outbound). 2008-09-24 01:54:11 +00:00
Mark Fisher
6655511d3d Refactored the ChannelAdapterParser to MethodInvokingInboundChannelAdapterParser. MethodInvokingOutboundChannelAdapterParser had already been committed. The namespace now defines "inbound-channel-adapter" and "outbound-channel-adapter" elements instead of using "channel-adapter" for both. 2008-09-24 01:42:28 +00:00
Mark Fisher
bc91df7db6 AbstractOutboundChannelAdapterParser now correctly invokes the 'parseAndRegisterConsumer()' method. 2008-09-24 01:26:01 +00:00
Mark Fisher
0ed3ba7657 Refactored CharacterStreamOutboundChannelAdapter to CharacterStreamWritingMessageConsumer and simplified the abstract method for AbstractOutboundChannelAdapter so that only a bean definition is returned (the base class now handles registration). 2008-09-24 00:00:55 +00:00
Mark Fisher
db33965e77 Added namespace support for the <transformer/> element (INT-342). 2008-09-23 22:36:01 +00:00
Mark Fisher
37840238d9 Cleaning out 'handler' pacakge within src/test. 2008-09-23 20:20:23 +00:00
Mark Fisher
699b3bec29 Committing modified ChannelAdapterAnnotationPostProcessor that missed the last commit. 2008-09-23 20:16:15 +00:00
Mark Fisher
8b59050571 Moved MethodInvokingConsumer from 'handler' to 'message', and replaced MessageFilter in 'handler' with FilterEndpoint in the new 'filter' package. 2008-09-23 20:07:04 +00:00
Mark Fisher
b4ab2d5365 Moved ReplyMessageCorrelator from the 'handler' package to the 'gateway' package (it is only used by SimpleMessagingGateway). 2008-09-22 22:52:23 +00:00
Mark Fisher
01e80f94ba Removed MethodArgumentMessageMapper. 2008-09-22 22:41:46 +00:00
Mark Fisher
b630f4a072 Refactored MethodArgumentMessageMapperTests to MessageMappingParameterResolverTests. 2008-09-22 22:38:49 +00:00
Mark Fisher
f07c7fc2fd Removed MessageHandlerRejectedExecutionException as it is no longer used, and moved MessageListMethodAdapter to the 'aggregator' package since that is the only place it is used (and it may be refactored away). 2008-09-22 22:28:18 +00:00
Mark Fisher
8a103b7ec5 Moved the MessageHandler interface into the 'org.springframework.integration.adapter' module/package since it is now only used for proxy-based Messaging Gateways. 2008-09-22 19:16:01 +00:00
Mark Fisher
7f917b5dd8 Removed MessageTarget. All components that referenced targets (e.g. Outbound Channel Adapter implementations) now work with the MessageConsumer interface instead. 2008-09-22 19:02:43 +00:00
Mark Fisher
83e078727d Config directories are no longer "Excluded-Exports". 2008-09-22 17:38:20 +00:00
Mark Fisher
de939c57f0 Removed the logic for detecting parser mappings from 'META-INF/spring-integration.parsers' files now that each module provides its own NamespaceHandler. 2008-09-22 17:05:38 +00:00
Mark Fisher
ee058d2696 Removed remaining references to 'spring-integration-core-1.0.xsd'. 2008-09-22 16:52:43 +00:00
Mark Fisher
e00cd62997 The "core" schema is now 'spring-integration-1.0.xsd' instead of 'spring-integration-core-1.0.xsd'. The adapters module no longer provides the combined schema, since the adapter modules have been separated - each with its own schema, namespace handler, and parsers. 2008-09-22 16:41:24 +00:00
Mark Fisher
b160734ce1 Added AbstractOutboundChannelAdapterParser and MethodInvokingOutboundChannelAdapterParser. 2008-09-22 03:55:28 +00:00
Mark Fisher
a35a8e1143 Added a getDefaultPollInterval() method and a "default-default" value of 1000 (1 second). 2008-09-22 00:21:26 +00:00
Mark Fisher
870ab7b9f4 SimpleMessagingGateway now implements InitializingBean and verifies that the 'requestChannel' is not null. 2008-09-20 19:23:02 +00:00
Mark Fisher
a14246bfca Added AbstractChannelAdapterParser base class. 2008-09-19 23:24:15 +00:00
Mark Fisher
873bbbf7a6 Added abstract modifier. 2008-09-19 20:03:35 +00:00
Mark Fisher
2d66b2b67d Refactored MethodInvokingTarget to MethodInvokingConsumer including changes to OutboundChannelAdapter. 2008-09-19 19:55:47 +00:00
Mark Fisher
bbc14e5bbe SimpleMessagingGateway now supports a subscribable channel for its 'replyChannel'. However, when attempting to use the gateway for simple 'receive' operations, an exception will be thrown if the replyChannel is not a PollableChannel. The subscribable channel is only a relevant option when relying upon reply-message correlation. 2008-09-19 13:19:13 +00:00
Mark Fisher
045f96e2c0 Added AbstractSubscribablChannel base class for DirectChannel and PublishSubscribeChannel. 2008-09-19 12:33:22 +00:00