Commit Graph

669 Commits

Author SHA1 Message Date
Mark Fisher
024c734333 Increased test timeout value. 2008-11-24 21:42:52 +00:00
Mark Fisher
79fdb179fc Added support for a top-level 'poller' element. A single top-level poller may have a value of 'default=true'. When using the namespace support, endpoints with pollable input-channels are now required to have an explicit poller sub-element or a 'default' poller within the context. The sub-element now also accepts a "ref" (INT-390). 2008-11-24 21:37:18 +00:00
Mark Fisher
5b654913f1 Creating child ParserContext with containingBeanDefinition to prevent extra bean definition registrations when parsing the child elements. 2008-11-24 19:45:34 +00:00
Mark Fisher
b16431e265 INT-492 2008-11-23 21:28:02 +00:00
Marius Bogoevici
b6c5c54ae6 INT-238, INT-371 minor correction 2008-11-23 07:54:45 +00:00
Marius Bogoevici
3ee1e4921e INT-238, INT-371 Clean up aggregator code, solve some robustness issues 2008-11-23 07:44:18 +00:00
Mark Fisher
f69d774e09 The default IntervalTrigger (with interval of 10ms) is being configured within the AbstractPollingEndpoint only. The ConsumerEndpointFactoryBean no longer provides a default trigger but rather only passes along a non-null trigger property if one is configured on the bean definition. 2008-11-23 04:19:15 +00:00
Mark Fisher
83e15fbb9b formatting, etc 2008-11-23 04:12:29 +00:00
Mark Fisher
5d414912e5 Added some debug logging. 2008-11-22 22:57:28 +00:00
Mark Fisher
55c62a06e6 Added namespace support for a 'bridge' element that simply connects any input-channel to any output-channel. This enables the conversion between PollableChannels and SubscribableChannels and also provides throttling capabilities based on the polling interval (or cron-expression) and 'max-messages-per-poll' settings (INT-193). 2008-11-22 22:03:36 +00:00
Mark Fisher
986049d23b Added MessagingBridge implementation. 2008-11-22 21:12:04 +00:00
Mark Fisher
f6e1463a42 Increased test timeout value. 2008-11-22 18:51:19 +00:00
Mark Fisher
4e72c719f9 Added the 'overwrite' attribute for the 'header-enricher' element. 2008-11-22 16:13:31 +00:00
Mark Fisher
abb370b257 Added the 'header-enricher' element to the core namespace (INT-489). 2008-11-22 15:43:39 +00:00
Mark Fisher
d943af0e87 Added postProcessHeaders method to the SimpleHeaderEnricherParser (preparing for INT-489). 2008-11-22 14:37:28 +00:00
Mark Fisher
086eb6e374 Converted internal header names to be hyphenated for compatibility with the header-enricher. 2008-11-22 14:35:32 +00:00
Mark Fisher
b53d96ba1e Added support for the 'throw-exception-on-rejection' attribute for the 'filter' element. 2008-11-21 22:52:11 +00:00
Mark Fisher
2b166d6471 INT-487 2008-11-21 22:03:27 +00:00
Mark Fisher
837a295cbe Added namespace support for the 'chain' element to create a Message Endpoint that delegates to a MessageHandlerChain (INT-391). 2008-11-21 18:34:07 +00:00
Mark Fisher
93a2d2c9f2 Renamed the 'parseConsumer' method to 'parseHandler' since it creates an implementation of MessageHandler. 2008-11-21 17:39:01 +00:00
Mark Fisher
b9f8b085b0 Removed 'parseAdapter' method from AbstractConsumerEndpointParser. 2008-11-21 17:30:25 +00:00
Mark Fisher
bbd58b830f INT-484 2008-11-21 16:05:53 +00:00
Mark Fisher
b4178d3740 Initial commit of MessageHandlerChain (INT-391). 2008-11-20 15:04:44 +00:00
Mark Fisher
f481b010b2 Renamed inner class from TemporaryReturnAddress to TemporaryReplyChannel since the Message header name is now 'replyChannel'. 2008-11-19 21:52:07 +00:00
Mark Fisher
13d12557e5 Added protected getBeanName() for subclass access. 2008-11-19 21:47:47 +00:00
Mark Fisher
8e09a38ce9 Added 'max-size' attributes to test configurations of the 'thread-pool-task-executor' element. 2008-11-19 18:50:03 +00:00
Mark Fisher
7badd53b9f INT-481 2008-11-19 17:37:39 +00:00
Mark Fisher
3d13f7e954 Increased test receive timeout value. 2008-11-19 17:09:10 +00:00
Mark Fisher
85d429d29f PublishSubscribeChannel now wraps a provided TaskExecutor with the ErrorHandlingTaskExecutor if necessary (INT-440). Also, added namespace support for the publish-subscribe-channel's 'error-handler' reference (INT-483). 2008-11-19 16:53:25 +00:00
Mark Fisher
1e1b2ce9b8 Triggers are now created as BeanDefinitions so that property placeholder values will be applied when parsing with the namespace support (INT-359). 2008-11-18 22:04:39 +00:00
Mark Fisher
5c752a86ec MessageMappingMethodInvoker no longer implements MethodInvoker (simplified - since it always requires a single Message arg). 2008-11-18 20:43:07 +00:00
Mark Fisher
8ca2c3227b MessageMappingMethodInvoker now delegates to an instance of HandlerMethodResolver. Multiple annotated methods or method name matches are possible, and in such cases, the Method-resolution will occur at runtime based on the payload type of the Message to be handled (INT-72 and INT-191). 2008-11-18 19:42:56 +00:00
Mark Fisher
38e3fae8c1 Added PayloadTypeMatchingHandlerMethodResolver. 2008-11-18 18:59:09 +00:00
Mark Fisher
0859124aba Added 'getCandidateHandlerMethods()' to HandlerMethodUtils. 2008-11-18 18:45:47 +00:00
Mark Fisher
637e124add Added StaticHandlerMethodResolver. 2008-11-18 17:30:52 +00:00
Mark Fisher
24afbf6059 Added HandlerMethodUtils. 2008-11-18 17:10:35 +00:00
Mark Fisher
709b488622 Added the HandlerMethodResolver strategy interface. 2008-11-18 16:55:46 +00:00
Mark Fisher
bd16a126c4 Moved MessageMappingMethodInvoker to the 'handler' package instead of 'message'. 2008-11-17 21:48:07 +00:00
Mark Fisher
82b1922ac9 Moved annotation-based method resolution into the MessageMappingMethodInvoker instead of the individual handler types (ServiceActivatingHandler, MethodInvokingRouter, and MethodInvokingSplitter). 2008-11-17 20:19:07 +00:00
Mark Fisher
e3ae9f6a0f GenericMessage's payload is now 'final'. 2008-11-17 19:32:36 +00:00
Mark Fisher
6a4a246e31 JmsOutboundGateway now throws a MessageTimeoutException in case a JMS reply Message is not received within the alloted timeout. The null object is no longer passed to the MessageConverter where a misleading Exception ("payload must not be null") was being thrown (INT-479). 2008-11-17 17:07:11 +00:00
Jonas Partner
14ef15af8f remove unused proxy 2008-11-13 22:25:05 +00:00
Jonas Partner
f8aff7d281 2008-11-13 22:11:07 +00:00
Mark Fisher
6b468da46d Removed the LifeycleSupport base class. SimpleTaskScheduler and AbstractEndpoint now provide their own Lifecycle implementations. Added an IntegrationObjectSupport class with convenient access to the 'channelResolver' and 'taskScheduler' instances. 2008-11-13 17:49:13 +00:00
Mark Fisher
6c554f929d Added namespace support for 'auto-startup' on endpoints (INT-463). 2008-11-13 16:15:38 +00:00
Mark Fisher
f5cc9b3591 Removed the MessageEndpoint interface (it defined no methods). AbstractEndpoint is still the base class for all Message-producing and Message-consuming components. 2008-11-13 02:15:25 +00:00
Mark Fisher
ab13665033 Relying on SpringTransactionAnnotationParser. Spring 2.5.6 added support for parsing the Transactional annotation directly rather than requiring an AnnotatedElement. 2008-11-13 01:52:13 +00:00
Mark Fisher
482465ff95 Added constructor for message and cause. 2008-11-12 21:50:18 +00:00
Mark Fisher
9e7d631a72 INT-302 2008-11-12 17:05:10 +00:00
Mark Fisher
0ef08a42ba PriorityChannel now uses a null semaphore to indicate an unbounded queue rather than relying on Integer.MAX_VALUE. 2008-11-12 16:56:09 +00:00