Commit Graph

373 Commits

Author SHA1 Message Date
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
Mark Fisher
e0318d6132 Renamed AbstractInOutEndpoint to AbstractMessageHandlingEndpoint to be consistent with AbstractMessageProducingEndpoint and AbstractMessageConsumingEndpoint. 2008-09-19 12:00:42 +00:00
Mark Fisher
b1dfee7473 Renamed the 'processMessage' method to 'onMessageInternal' (it is the subclass implementation that is invoked from the base class 'onMessage' method). 2008-09-19 02:56:47 +00:00
Mark Fisher
866c9757e1 DefaultMessageBus simplifications. 2008-09-18 22:52:06 +00:00
Mark Fisher
eb5884a7d6 Removed EndpointRegistry. DefaultMessageBus now delegates to the ApplicationContext for all endpoint lookups, and the annotation-based post-processing registers singletons with the context rather than going through the DefaultMessageBus. 2008-09-18 22:42:08 +00:00
Mark Fisher
d8ebbe5994 Inbound Channel Adapter property is now "outputChannel" instead of just "channel". 2008-09-17 23:53:25 +00:00
Mark Fisher
8f9c709f25 Renamed InboundChannelAdapter to SourcePollingChannelAdapter since other event-driven inbound Channel Adapters may extend AbstractMessageProducingEndpoint directly. 2008-09-17 23:29:46 +00:00
Mark Fisher
baa1474ef9 InboundChannelAdapter now extends AbstractMessageProducingEndpoint. 2008-09-17 23:10:16 +00:00
Mark Fisher
6e56e8acbe Renamed MessageBuilder.fromPayload() to MessageBuilder.withPayload(). 2008-09-17 22:57:58 +00:00
Mark Fisher
6d4bc55520 Renamed AbstractProducerEndpoint to AbstractMessageProducingEndpoint (consistent with AbstractMessageConsumingEndpoint). 2008-09-17 22:36:50 +00:00
Mark Fisher
713c1a62db minor doc update 2008-09-17 21:53:20 +00:00
Mark Fisher
5a0677af00 Added AbstractPollingInboundChannelAdapterParser. 2008-09-17 21:30:12 +00:00
Mark Fisher
a2544f5b8e Added AbstractProducerEndpoint. 2008-09-17 19:16:19 +00:00
Mark Fisher
21d98f353d Removed 'handler' and 'handler-chain' elements from the XSD. 2008-09-17 12:41:29 +00:00
Mark Fisher
09f9161899 MessageBus interface no longer extends DisposableBean. Now, the DefaultMessageBus implementation implements DisposableBean directly. 2008-09-17 12:40:46 +00:00
Marius Bogoevici
3fb198f928 Adding an endpoint test for null-returning Aggregators 2008-09-17 04:33:15 +00:00
Marius Bogoevici
445a7e4e03 In completion to INT-369, adding test cases for null-returning and void-returning Aggregator methods. 2008-09-17 02:50:26 +00:00
Iwein Fuld
e59b11381b OPEN - issue INT-369: Nullpointer in AggregatingMessageHandler
http://jira.springframework.org/browse/INT-369
Added nullcheck and moved isEmpty check to MethodInvokingAggregator
2008-09-16 20:01:12 +00:00
Mark Fisher
473ac068d1 TaskScheduler no longer defines a setErrorHandler() method. 2008-09-15 14:11:29 +00:00
Mark Fisher
ccb9ba4197 Removed DefaultEndpointRegistry. The DefaultMessageBus now implements the EndpointRegistry interface directly. 2008-09-15 13:57:27 +00:00