Commit Graph

559 Commits

Author SHA1 Message Date
Mark Fisher
379fed3f5b Refactored to associate latch with trigger instead of consumer. 2008-10-20 19:06:36 +00:00
Mark Fisher
6e4b501ec6 Moving the MethodPublishingInterceptor and @Publisher annotation support to the sandbox for now. 2008-10-20 17:55:36 +00:00
Mark Fisher
df8bf6ed8f Removed DefaultErrorChannel. 2008-10-20 15:52:36 +00:00
Mark Fisher
1dc2c175a2 Removed AbstractPoller and ChannelPoller. Refactored test cases to use PollingConsumerEndpoint. 2008-10-20 15:27:03 +00:00
Mark Fisher
f8b2724f7a ApplicationContextMessageBus now implements the ChannelResolver interface. The MessagePublishingErrorHandler for the SimpleTaskScheduler is now created in the MessageBusParser rather than in the initialization code of the MessageBus. 2008-10-20 13:50:22 +00:00
Mark Fisher
7124894646 MessagePublishingErrorHandler is now BeanFactoryAware and therefore capable of creating a default BeanFactoryChannelResolver. 2008-10-20 13:45:43 +00:00
Mark Fisher
b6bd0b30fc Created 'consumer' package and moved consumer implementations from 'message' and 'endpoint' packages. 2008-10-20 12:09:30 +00:00
Mark Fisher
31f1116cff Renamed DefaultMessageBusTests to ApplicationContextMessageBusTests (to match the renamed class under test). 2008-10-20 11:41:50 +00:00
Mark Fisher
25d0ac78b6 INT-435 2008-10-20 11:38:00 +00:00
Mark Fisher
e31520bc64 Renamed DefaultMessageBus to ApplicationContextMessageBus. 2008-10-20 10:43:16 +00:00
Mark Fisher
7f7fb10ae5 Added RouterFactoryBean. MethodInvokingRouter now provides a constructor to accept the 'targetObject' only (without a method or methodName). It will resolve a single method annotated with @Router or else fallback to a single public method (INT-433, INT-434). 2008-10-19 23:02:18 +00:00
Iwein Fuld
f099083d66 RESOLVED - issue INT-431: AbstractMessageBarrierConsumer calls processMessages twice
http://jira.springframework.org/browse/INT-431

Reworked testcase
2008-10-19 14:41:49 +00:00
Iwein Fuld
88b27fd9a9 IN PROGRESS - issue INT-431: AbstractMessageBarrierConsumer calls processMessages twice
http://jira.springframework.org/browse/INT-431
2008-10-19 13:05:24 +00:00
Iwein Fuld
3b769ee134 removed hamcrest (resolving error when running tests from eclipse) 2008-10-19 12:10:39 +00:00
Mark Fisher
55eb3ae05d MessageHeaders no removes any non-serializable values from its map upon serialization. A warn-level notification will be logged. 2008-10-17 15:04:10 +00:00
Mark Fisher
2cf1d7629e INT-428 2008-10-16 19:47:39 +00:00
Mark Fisher
f750be097f AbstractMessagingGateway now automatically throws the exception payload of a received ErrorMessage in send-and-receive operations is the 'shouldThrowErrors' value is set to true. It is true by default (related to INT-301). 2008-10-16 16:39:19 +00:00
Mark Fisher
a8b2918680 SubscribingConsumerEndpoint now extends AbstractEndpoint. 2008-10-16 15:36:30 +00:00
Mark Fisher
d8f750f077 Added toString() methods. 2008-10-16 15:33:33 +00:00
Mark Fisher
bd52dc6627 MessageChannelTemplate now sets its temporary reply channel as the errorChannel header along with the replyChannel header. 2008-10-16 14:47:51 +00:00
Mark Fisher
de25b6bd5c SimpleTaskScheduler logs at error-level now, but only if no errorHandler is available. 2008-10-16 14:39:09 +00:00
Mark Fisher
ae698b61fd MessagePublishingErrorHandler now retrieves the 'errorChannel' header from the 'failedMessage' of a MessagingException (if available). It resolves it if necessary (if it is a channel name instead of MessageChannel instance) by delegating to a ChannelResolver. 2008-10-16 02:36:25 +00:00
Mark Fisher
2f009b607b Creating the TaskScheduler as a bean definition within the context in MessageBusParser instead of instantiating with a constructor call. 2008-10-16 01:03:52 +00:00
Mark Fisher
0f52b88851 Added hamcrest to .classpath. 2008-10-16 00:51:38 +00:00
Mark Fisher
a8694526ec Removed the 'errorHandler' property from AbstractMessageConsumer and the 'error-handler' attribute from the schema. Will be adding configurable errorChannel Message header instead. 2008-10-15 22:21:27 +00:00
Mark Fisher
e6af632f7d Added 'errorChannel' header. 2008-10-15 21:41:39 +00:00
Mark Fisher
18b65fdf0a Renamed the 'pool-executor' element to 'thread-pool-task-executor' (INT-426). 2008-10-15 19:45:58 +00:00
Mark Fisher
905f76116f MessageHeaders now copies the Map passed into its constructor to enforce immutability of the Map itself (note: mutability of the values in the Map is intentionally left as a development decision). The clear() method now correctly throws UnsupportedOperationException along with the other Map methods that would otherwise be capable of modifying the Map (INT-427). 2008-10-15 19:38:53 +00:00
Mark Fisher
8a8e2b035c SimpleTaskScheduler now invokes destroy() on its TaskExecutor if that executor implements DisposableBean (INT-393). 2008-10-15 18:58:58 +00:00
Mark Fisher
11e3fbb584 Removed BlockingChannel interface. The send(message, timeout) method is now defined directly in the top-level MessageChannel interface. 2008-10-15 16:49:00 +00:00
Mark Fisher
0afc835679 Reorganized DefaultMessageBus methods. 2008-10-15 16:19:04 +00:00
Mark Fisher
8e24ef2dd0 Renamed 'setReturnAddress(MessageChannel)' in MessageBuilder to 'setReplyChannel(MessageChannel)'. Also, the version that takes a String instead of a MessageChannel is now named 'setReplyChannelName(String)' for clarity. 2008-10-15 16:08:55 +00:00
Mark Fisher
344e1cecd7 Renamed 'returnAddress' in MessageHeaders to 'replyChannel'. 2008-10-15 15:55:37 +00:00
Mark Fisher
fc9109e5cb Refactored invokeMethod() method. 2008-10-15 03:44:17 +00:00
Mark Fisher
ebcccdc5c9 Moved MessagingException into the new 'org.springframework.integration.core' package. 2008-10-15 03:28:50 +00:00
Mark Fisher
262bd8fd9c Moved MessageChannel into the new 'org.springframework.integration.core' package. 2008-10-15 03:19:28 +00:00
Mark Fisher
2d84ee860b Moved MessagePriority into the new 'org.springframework.integration.core' package. 2008-10-15 03:12:47 +00:00
Mark Fisher
7da7c9e5a0 Moved MessageHeaders into the new 'org.springframework.integration.core' package. 2008-10-15 03:10:17 +00:00
Mark Fisher
8c6b7a6921 Updated GenericMessage's import of Message (somehow this was skipped in the previous commit). 2008-10-15 03:01:05 +00:00
Mark Fisher
08043b541d Moved Message into the new 'org.springframework.integration.core' package. 2008-10-15 02:54:29 +00:00
Mark Fisher
7ef7f57c2b Renamed MessageSelectorChain's enum from Strategy to VotingStrategy and changed MORE_THAN_HALF and AT_LEAST_HALF to MAJORITY and MAJORITY_OR_TIE respectively. 2008-10-14 18:20:01 +00:00
Mark Fisher
21eefa90dc Added namespace support for a MessageSelectorChain's Strategy (ALL, ANY, AT_LEAST_HALF, MORE_THAN_HALF), and added support for nesting <selector-chain/> elements (INT-308). 2008-10-14 17:39:14 +00:00
Mark Fisher
109343d14e Moved MessageSelector interface and implementations into a new 'org.springframework.integration.selector' package (instead of a sub-package under 'message'). Also added support for "Strategy" enum in MessageSelector with the following values available [ALL, ANY, AT_LEAST_HALF, MORE_THAN_HALF] (INT-308). 2008-10-14 16:16:55 +00:00
Mark Fisher
9286f1fdaa Refactored tests. 2008-10-14 15:19:04 +00:00
Mark Fisher
5f6e6277cd ServiceActivatorEndpoint is now ServiceActivatingConsumer. 2008-10-14 15:06:18 +00:00
Mark Fisher
10fd9304f0 Removed ServiceActivatorEndpoint from MethodInvokingConsumerTests. 2008-10-14 14:42:16 +00:00
Mark Fisher
79d9d8dc07 DefaultMethodResolver and AnnotationMethodResolver now use the target class of an AOP proxy. Added tests to DefaultMethodResolverTests: 'jdkProxy' and 'cglibProxy' (INT-425). 2008-10-14 14:16:49 +00:00
Mark Fisher
b7f4c1c1e9 Added the 'time-unit' attribute to <interval-trigger/> (INT-424). 2008-10-14 12:42:09 +00:00
Mark Fisher
7ccc8f28d5 The <poller/> element no longer defines trigger properties (interval, initial-delay, cron, etc). Instead it expects a sub-element - either <interval-trigger/> or <cron-trigger/> (INT-423). 2008-10-14 12:25:56 +00:00
Marius Bogoevici
3e669903a4 Fixes configuration, so that the poller can be used. 2008-10-14 02:46:57 +00:00