Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
549 Commits 25 Branches 0 Tags
cc7f1cb91a0d0a8ea59ae2dd4a75eabc8d03d885
Commit Graph

315 Commits

Author SHA1 Message Date
Mark Fisher
cc7f1cb91a Enforcing that a <source-endpoint/> element always contains exactly one <schedule/> sub-element. 2008-05-03 22:55:55 +00:00
Mark Fisher
4c0c3677d0 The <jms-gateway/> element is now available for message-driven JMS adapters. The <jms-source/> is strictly for polling adapters. Provided basic foundation for converting other request-reply adapters into "gateways". This includes the following namespace changes: 'send-timeout' is now 'request-timeout', 'receive-timeout' is now 'reply-timeout', and the 'channel' element is now 'request-channel'. The Source interface now includes the receive() method itself. PollableSource and SubscribableSource interfaces have both been removed. The Subscribable interface was added (e.g. for SynchronousChannel), but "gateway" adapter types will be configured directly with a request channel (and optionally a response channel). 2008-05-03 22:23:40 +00:00
Marius Bogoevici
4f42fe7227 Adding MessageBus, previously omitted. 2008-05-02 21:16:35 +00:00
Marius Bogoevici
0d8e8fc6ee Adding ChannelFactory, various implementations for different types of channels and DefaultChannelFactoryBean. 2008-05-02 21:10:18 +00:00
Marius Bogoevici
82ecd5f5b8 <message-bus/> will automatically add a MessageBusAwareBeanPostProcessor to the context. 2008-05-02 06:10:18 +00:00
Marius Bogoevici
d0041dd8ad Adding class ommitted from previous checkin. 2008-05-02 05:21:20 +00:00
Marius Bogoevici
cc5011428d Added the MessageBusAware interface, as well as the MessageBusAwareBeanPostProcessor for injecting the MessageBus in the implementing beans. 2008-05-02 05:11:17 +00:00
Mark Fisher
78905d9bcb Added MessagingGateway as a subclass of RequestReplyTemplate that is also a superclass for the GatewayProxyFactoryBean. 2008-05-01 13:09:11 +00:00
Mark Fisher
369ea90b24 Refactored ChannelParser into a hierarchy of parsers. Added namespace support for "rendezvous-channel" and "direct-channel" (a.k.a. SyncrhonousChannel at this point). 2008-04-28 23:59:43 +00:00
Mark Fisher
d252605bdb The "defaultOutputChannelName" property of HandlerEndpoint is now "outputChannelName", and the "defaultOutput" attribute of the @MessageEndpoint annotation is now "output". 2008-04-27 06:00:40 +00:00
Mark Fisher
09333d62cb The <handler-endpoint/> element's "default-output-channel" attribute is now "output-channel". Since the new "return-address-overrides" value is true by default, the "output-channel" takes precedence rather than being a fallback. 2008-04-27 05:29:59 +00:00
Mark Fisher
9eaa088052 The <endpoint/> element is now <handler-endpoint/>, and its "handler-method" attribute is now "method". 2008-04-27 05:01:38 +00:00
Mark Fisher
412c5b3134 Added namespace support for target-endpoint. 2008-04-27 02:25:53 +00:00
Mark Fisher
64c498838c GatewayProxyFactoryBean now supports receive-only operations. Also added support for timeouts and type-conversion. 2008-04-25 19:14:14 +00:00
Mark Fisher
24a15520ba PollingSourceEndpoint now provides initializeTask() for one-time only as well as refreshTask() to reconfigure proxies at runtime. 2008-04-25 15:18:39 +00:00
Mark Fisher
2147ac43ed Restricting advice to the "run" method of MessagingTask, and added synchronization for proxy initialization. 2008-04-25 12:45:12 +00:00
Mark Fisher
c92b24f959 Added initial implementation of GatewayProxyFactoryBean. 2008-04-24 23:41:52 +00:00
Mark Fisher
cfb0d7e2fd Added 'taskAdviceChain' and 'dispatchAdviceChain' to PollingSourceEndpoint. 2008-04-24 19:57:27 +00:00
Mark Fisher
467e0f803d PollingSourceEndpoint delegates to PollingDispatcher. Added sendTimeout to SimpleDispatcher. 2008-04-24 14:25:34 +00:00
Mark Fisher
9c67c1516f Added more tests for returnAddress and output channel. 2008-04-24 11:36:14 +00:00
Mark Fisher
7d3755c099 Added "returnAddressOverrides" property for endpoints ('return-address-overrides' in XML). The default value is 'false' indicating that any explicitly defined output channel should take precedence. 2008-04-24 03:41:50 +00:00
Mark Fisher
28f914748b ChannelAdapterParser is now MethodInvokingAdapterParser and only creates the source or target. The result should be configured with a SourceEndpoint or TargetEndpoint. 2008-04-24 00:43:08 +00:00
Mark Fisher
4d19a02f15 Added PollingSourceEndpoint, removed PollingSourceAdapter, and source-adapter parsers only parse the Source itself. 2008-04-23 23:47:02 +00:00
Mark Fisher
9f3bc80949 Factored out the common target endpoint type to enable change to 'target-endpoint' and 'handler-endpoint'. 2008-04-23 14:18:01 +00:00
Mark Fisher
9fd30d1ed4 Moved awareness of SynchronousChannel out of the MessageBus and into the SubscriptionManager. 2008-04-23 13:37:27 +00:00
Mark Fisher
bf0f8b16ec SimpleChannel is now QueueChannel. Also added RendezvousChannel for the zero-capacity SynchronousQueue-based version. 2008-04-22 20:26:19 +00:00
Mark Fisher
4b01a3a09c The <endpoint/> element now expects a "handler" attribute instead of "handler-ref". 2008-04-22 18:17:05 +00:00
Mark Fisher
cb3c4fbdc3 Removed support for <handler/> sub-element for <endpoint/> since the 'handler-ref' attribute is sufficient. 2008-04-22 17:44:23 +00:00
Mark Fisher
3d63406053 MessageBus now registers endpoints and source adapters (and starts if its autoStartup property is set to "true") after receiving a ContextRefreshedEvent rather than the excessively eager start during the 'setApplicationContext' callback (INT-196). 2008-04-22 16:56:27 +00:00
Mark Fisher
c9cdff0aee Added removeAttribute() and removeProperty() methods (INT-203, INT-204). 2008-04-22 13:40:42 +00:00
Mark Fisher
e0563a6173 Checking for null prior to setting the channelRegistry on the endpoint's handler (short term fix for INT-202). 2008-04-21 20:51:38 +00:00
Mark Fisher
d30f3230b0 Simplified Message dispatching. Removed MessageRetriever and MessageDistributor (and the "default" implementations). Added SimpleDispatcher and PollingDispatcher. Added the SubscribableSource interface and a SubscriptionManager to simplify the coordination of dispatchers within the MessageBus. These changes also lay the groundwork for further refactoring of the various Source and SourceAdapter implementations. 2008-04-18 21:26:31 +00:00
Mark Fisher
0bd9ea9255 TargetEndpoint now returns false when one of its MessageSelectors rejects a Message rather than throwing an Exception. Added Source, BlockingSource, and BlockingTarget interfaces. MessageChannel now extends BlockingSource and BlockingTarget. 2008-04-17 21:06:14 +00:00
Mark Fisher
0f6bd60ee0 Added Target interface and split DefaultMessageEndpoint into TargetEndpoint and HandlerEndpoint. All "one-way" adapters now implement Target instead of MessageHandler, the ConcurrentHandler is now ConcurrentTarget, and the MessageDispatcher also operates on Targets rather than MessageHandlers. 2008-04-17 17:25:56 +00:00
Mark Fisher
e9673586c4 On destruction, ConcurrentHandler calls shutdownNow() on its Executor rather than shutdown(). 2008-04-16 19:50:32 +00:00
Mark Fisher
a0072b3e66 DefaultMessageEndpoint constructor now requires a MessageHandler. The endpoint no longer invokes Lifecycle methods on the MessageHandler. 2008-04-16 19:14:26 +00:00
Mark Fisher
9710edaa3c If no ErrorHandler is available, errors will be logged at WARN level (INT-138). 2008-04-16 18:47:12 +00:00
Mark Fisher
7edfc96f5e MessageHandlingExceptions (other than selector-rejection, handler-not-running, and executor-rejection) are now propagated from DefaultMessageDistributor (INT-184). 2008-04-16 18:07:14 +00:00
Mark Fisher
550a674850 committing AbstractSourceAdapter manually (missed by plugin) 2008-04-16 16:38:44 +00:00
Mark Fisher
b5e01b447a Providing better separation between PollableSource and PollingSourceAdapter (work in progress). 2008-04-16 16:31:24 +00:00
Marius Bogoevici
19aad42c9e INT-198 Ensure that the sequence size and sequence number are copied. 2008-04-15 22:26:47 +00:00
Mark Fisher
ffacaabf64 Increased timeout value for retrieval tests that should occur within the allotted timeout. 2008-04-13 15:55:54 +00:00
Mark Fisher
167da2f28c Increased delay for publishing to the MessageStore when testing blocking retrieval that should timeout. 2008-04-12 16:12:28 +00:00
Mark Fisher
18b096f69f Now enforcing that a message endpoint must contain a handler method (INT-177). 2008-04-12 16:02:20 +00:00
Mark Fisher
3ef001545f Added test for Splitter annotation now that the output channel is propagated from @MessageEndpoint. 2008-04-11 22:25:21 +00:00
Mark Fisher
1835a9e0ed Added the correlationId, expiration, priority, and sequence number to MessageHeader's toString(). 2008-04-11 19:21:01 +00:00
Mark Fisher
88ac6af364 The @Splitter annotation no longer has a "channel" attribute. Instead it uses the @MessageEndpoint's "defaultOutput" attribute (INT-189). 2008-04-11 19:13:45 +00:00
Mark Fisher
b7517caaba SplitterMessageHandlerAdapter no longer does unnecessary type-check prior to method invocation (INT-190). 2008-04-11 16:33:21 +00:00
Mark Fisher
6842be8e40 MessagePublishingErrorHandler is no longer set on a Message Endpoint that is itself subscribing to the "errorChannel". 2008-04-11 15:32:05 +00:00
Mark Fisher
87e5edb0dc PollingSourceAdapter does schedule tasks when connected to a SynchronousChannel (INT-187). 2008-04-11 12:18:03 +00:00