Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Commit Graph

  • b37a4d8f12 Removed MessageTransformer due to the redundancy with MessageHandler (now that Messages are immutable). Refactored existing transformers to implement PayloadTransformer instead. All message handling is now the responsibility of the delegating PayloadTransformingMessageHandler. Also added the AbstractPaylaodTransformerParser from which all existing PayloadTransformer parsers now extend. Mark Fisher 2008-07-18 20:12:59 +00:00
  • 3a916b223d Fixes INT-305 - lazy initialization of DefaultChannelFactoryBean. Marius Bogoevici 2008-07-18 19:59:00 +00:00
  • a9a498f3fc Added PayloadTransformer strategy interface, MethodInvokingPayloadTransformer, and PayloadTransformingMessageHandler. Mark Fisher 2008-07-18 18:09:24 +00:00
  • 9487837186 Refactored from @HeaderAttribute and @HeaderProperty to a single @Header annotation now that MessageHeaders contains a single map (INT-306). Mark Fisher 2008-07-18 17:33:13 +00:00
  • a3b1c59d10 JmsTarget and JmsSource now check if the provided messageConverter is already a HeaderMappingMessageConverter and if so do not wrap it again (INT-304). Mark Fisher 2008-07-18 14:50:21 +00:00
  • 2db30ae829 MessageBuilder's copyHeaders(..) method now accepts a Map<String, Object> so there is no need to create the MessageHeaders object. Mark Fisher 2008-07-18 13:26:39 +00:00
  • 7231e0867c Removed MessageBuilder copyHeadersFromMessage and copyHeaderFromMessageIfAbsent methods. Mark Fisher 2008-07-18 13:13:23 +00:00
  • d854a8e9d8 Added MessageHeaders and MessageBuilder. Messages are now immutable (including header maps). Mark Fisher 2008-07-17 23:08:53 +00:00
  • 2c95306f63 Added MessageHeaders and MessageBuilder. Messages are now immutable (including header maps). Mark Fisher 2008-07-17 22:58:56 +00:00
  • b9ea75ea98 Namespace support for XPathRouter INT-300 Jonas Partner 2008-07-17 09:06:56 +00:00
  • 8dfe625163 Moved ChannelRegistryAware and InitializingBean interfaces to the AbstractEndpoint class declaration instead of the MessageEndpoint interface. Mark Fisher 2008-07-16 01:38:41 +00:00
  • d344504e38 Message payload can no longer be set. MessageTransformer's transform() method now returns a Message (instead of void). ChannelInterceptor preSend() and postReceive() methods now return a Message instead of boolean. Mark Fisher 2008-07-15 22:43:47 +00:00
  • 0056edd10d Message timestamp is now a long (instead of java.util.Date). Mark Fisher 2008-07-15 19:16:52 +00:00
  • cb7fe54f17 Only creating a DefaultEndpointPoller if the source is not a Subscribable channel. Mark Fisher 2008-07-15 19:04:25 +00:00
  • 1b98a3e647 INT-300 XPathRouter Name space support to follow Jonas Partner 2008-07-15 16:44:12 +00:00
  • 7d3eac5611 changed org.springframework.test dependency to test->runtime Jonas Partner 2008-07-15 16:42:44 +00:00
  • b45514003c Implemented TriggerMessage with an EndpointPoller as its payload for convenience when triggering polling of an endpoint. Mark Fisher 2008-07-14 23:11:54 +00:00
  • 8f1cf63f5e Added support (in the schema) for the <poller/> sub-element within a <channel-adapter/> and added a setSource(MessageSource) method to DirectChannel. Mark Fisher 2008-07-14 22:49:38 +00:00
  • 77022d0519 DefaultEndpointPoller now implements InitializingBean (to prepare the transactionTemplate), and the poller element parsing now includes the PROPAGATION_ and ISOLATION_ prefixes to properly configure those transaction attributes from the enumerated values defined in the schema. Mark Fisher 2008-07-14 20:01:09 +00:00
  • a645841d66 Added support for the <poller/> sub-element within <service-activator/> and <channel-adapter/>. Mark Fisher 2008-07-14 19:27:58 +00:00
  • 6438bba84f Added support for the <poller/> sub-element within <service-activator/> and <channel-adapter/>. Mark Fisher 2008-07-14 19:19:46 +00:00
  • ca7dc3922e Endpoints now expose a setter for a Poller strategy and no longer implement Lifecycle. Mark Fisher 2008-07-14 18:29:07 +00:00
  • 9bcd9e12c8 Added DefaultEndpointPoller. Mark Fisher 2008-07-14 17:49:24 +00:00
  • 9c8bf25f3e Added registration for PoolExecutorParser. Mark Fisher 2008-07-14 13:26:06 +00:00
  • 4dd443e6c8 Added Poller interface and SimplePoller implementation. Mark Fisher 2008-07-14 12:38:05 +00:00
  • 5993be4d6c Added PoolExecutorParser. Mark Fisher 2008-07-13 21:26:13 +00:00
  • 6bc2ee1ff2 AbstractDispatcher now delegates to a TargetInvoker. Mark Fisher 2008-07-13 16:00:11 +00:00
  • 0efe7990d0 Added SourceInvoker and TargetInvoker helper classes. Mark Fisher 2008-07-13 15:32:41 +00:00
  • 589206352f Updated cafeDemo.xml for release packaging Mark Fisher 2008-07-10 09:24:44 +00:00
  • 58896de557 Added more tests for WebServiceHandlerParser with 'messageFactory'. Mark Fisher 2008-07-10 08:38:09 +00:00
  • d85b9da3be updated version number Mark Fisher 2008-07-10 02:32:57 +00:00
  • 7a2dd68965 The WebServiceHandlerParser now provides the WebServiceMessageFactory in the WebServiceTemplate constructor (INT-295). Mark Fisher 2008-07-10 01:54:46 +00:00
  • a3a50488d8 Added receiveTimeout and sendTimeout properties to SourceEndpoint. Mark Fisher 2008-07-10 01:01:34 +00:00
  • 882cba8a07 Added default values. Mark Fisher 2008-07-10 00:55:05 +00:00
  • 92746ebed6 Post interceptors are invoked in the reverse order of pre interceptors Mark Fisher 2008-07-09 14:09:25 +00:00
  • 0b25056392 Updated documentation for endpoint interceptors Mark Fisher 2008-07-09 12:29:06 +00:00
  • a0d3e55ee7 Modified configuration to use 'service-activator' Mark Fisher 2008-07-09 12:28:39 +00:00
  • a04b940de6 Refactored interceptors to use EndpointInterceptor interface rather than Advice. Mark Fisher 2008-07-09 12:24:33 +00:00
  • dfd7bf551c Refactored interceptors to use EndpointInterceptor interface rather than Advice. Mark Fisher 2008-07-09 12:24:16 +00:00
  • f9150886db Updated configuration documentation. Mark Fisher 2008-07-08 07:54:27 +00:00
  • 58eda9089b Updated adapters documentation. Mark Fisher 2008-07-08 04:31:11 +00:00
  • a22d205008 Updated 'samples' documentation. Mark Fisher 2008-07-08 03:58:42 +00:00
  • 08b56b3666 Updating reference documentation for M5. Mark Fisher 2008-07-08 03:33:24 +00:00
  • a9e7146170 Added NullChannel. Mark Fisher 2008-07-08 03:10:28 +00:00
  • 90e19ce968 Updated changelog and readme for M5. Mark Fisher 2008-07-08 03:08:13 +00:00
  • 1cc12ce4bf Replaced <handler-endpoint/> with <service-activator/> in cafeDemo.xml Mark Fisher 2008-07-08 02:35:49 +00:00
  • f96d4b8d88 Removed DispatcherPolicy (INT-292). Mark Fisher 2008-07-08 02:18:41 +00:00
  • b3719ff096 Added namespace support for "message-factory" and "fault-message-resolver" (INT-291). Mark Fisher 2008-07-08 01:03:06 +00:00
  • f8e7bdf3c2 Setting ChannelRegistry in MessageBusAwareBeanPostProcessor and avoiding potential NPE in ConcurrencyInterceptor (when ChannelRegistry has not been set). Mark Fisher 2008-07-07 11:58:12 +00:00
  • c0eecad7df Namespace support for XSLT transformer Jonas Partner 2008-07-07 07:30:32 +00:00
  • 47c456e24b Modified test configuration after package removal. Mark Fisher 2008-07-07 01:57:04 +00:00
  • 590f7e9f26 Consolidated security parsers into the main 'config' package (avoids a tangle). Mark Fisher 2008-07-07 01:54:41 +00:00
  • 47d4093a93 Removed 'bus.interceptor' package for now (avoids a tangle). Mark Fisher 2008-07-07 01:50:30 +00:00
  • 9409594a1c Removed 'bus.interceptor' package for now (avoids a tangle). Mark Fisher 2008-07-07 01:47:34 +00:00
  • 69e18fcf95 Removed getTrigger() method from MessageEndpoint (avoids a tangle). It is not yet used. Mark Fisher 2008-07-07 01:43:59 +00:00
  • c7250f3ea5 Moved PublishSubscribeChannel to 'dispatcher' package since it depends on dispatchers (avoids a tangle). Also moved the PublishSubscribeChannelParser into 'config'. Mark Fisher 2008-07-07 01:12:52 +00:00
  • c2d5f802c9 Moved RouterParser and SplitterParser into 'config' instead of 'router.config' (avoids a tangle). Mark Fisher 2008-07-07 01:04:10 +00:00
  • 0194945ec3 ConcurrencyInterceptor implements ChannelRegistryAware instead of MessageBusAware (removes a tangle). Mark Fisher 2008-07-07 00:59:20 +00:00
  • 2c6f496ca7 Removed AopContext.currentProxy() call for now. Mark Fisher 2008-07-06 22:50:55 +00:00
  • 3b6207571f Added more request/reply tests for SimpleMessagingGateway. Mark Fisher 2008-07-06 22:40:16 +00:00
  • 99af66481d MessageHeader is now an interface. The DefaultMessageHeader class is the implementation used by GenericMessage (INT-288). Mark Fisher 2008-07-06 22:34:51 +00:00
  • 9c49063a3c MessagingGatewaySupport is now MessageBusAware. Added request/reply tests for SimpleMessagingGateway. Mark Fisher 2008-07-06 22:17:12 +00:00
  • d731f8fb70 MessageBus is now an interface. The DefaultMessageBus class is the implementation. Mark Fisher 2008-07-06 22:11:44 +00:00
  • 2afcf4c490 MessageBus is now an interface. The DefaultMessageBus class is the implementation. Mark Fisher 2008-07-06 22:09:07 +00:00
  • bfd3d5392b Using direct-channel for input and split. Mark Fisher 2008-07-06 20:56:55 +00:00
  • 5dc6488de0 The <aggregator/> element now creates a HandlerEndpoint instance. It now requires "input-channel" and "output-channel" (and it no longer accepts "default-reply-channel"). It also no longer accepts a <completion-strategy/> sub-element. Instead, for a pojo-based adapter, add the "completion-strategy-method" attribute along with the "completion-strategy" reference (INT-285). Mark Fisher 2008-07-06 20:35:36 +00:00
  • 2128c1e21e added Result transformer INT-286 Refactored OXM transformer creating separate marshalling and unamarshalling transformers and added namespace support INT-109 Jonas Partner 2008-07-06 20:35:31 +00:00
  • b7f31fcbf0 The <router/> element now creates its own endpoint (i.e. it is no longer necessary to create a <handler-endpoint/> as well) (INT-284). Mark Fisher 2008-07-06 18:08:31 +00:00
  • a83e39b6ce The <splitter/> element now creates its own endpoint (i.e. it is no longer necessary to create a <handler-endpoint/> as well) (INT-283). Also, the <handler-endpoint/>'s "handler" attribute has been replaced with "ref" to be more consistent with other spring configuration options (e.g. defining jms-listeners with the JMS namespace support). Mark Fisher 2008-07-06 17:36:42 +00:00
  • 1b90086e4e Endpoints now recognize an EndpointVisitor in the message payload. The EndpointPoller is now an implementation of EndpointVisitor (removed PollCommand). Mark Fisher 2008-07-06 03:09:56 +00:00
  • 06f4e1d011 Added support for a 'filename-pattern' attribute on <file-source/>. It creates a RegexPatternFilenameFilter instance and sets it on the FileSource (INT-252). Mark Fisher 2008-07-05 23:49:23 +00:00
  • 5d25b93461 ChannelFactory now accepts the channel name (INT-280). Mark Fisher 2008-07-05 22:59:25 +00:00
  • 9b787a0d5a MessageBus now does a second pass to pick up any MessageChannel that has been provided between the setApplicationContext callback and the ContextRefreshedEvent (INT-270). Mark Fisher 2008-07-05 22:26:11 +00:00
  • 248209bf00 Annotation-based aggregator methods now use the output channel specified in a class-level @MessageEndpoint annotation. The 'defaultReplyChannel' property is no longer available on the @Aggregator annotation itself (INT-274). Mark Fisher 2008-07-05 21:57:25 +00:00
  • f479a877b3 Removed TargetEndpointParser. Mark Fisher 2008-07-05 21:16:27 +00:00
  • 3747de3c7a Modified demos to replace 'target-endpoint' with 'channel-adapter' elements. Mark Fisher 2008-07-05 20:14:42 +00:00
  • 1a6448b3d8 Changed 'target-endpoint' to 'channel-adapter'. Mark Fisher 2008-07-05 20:07:35 +00:00
  • b2be3f4d58 Changed 'source-endpoint' to 'channel-adapter'. Mark Fisher 2008-07-05 20:04:37 +00:00
  • 5a40f17826 Both "source-endpoint" and "target-endpoint" elements are now configured as <channel-adapter/>. That element requires exactly one of "source" or "target" and optionally accepts a "method" attribute for creating either a MethodInvokingSource or a MethodInvokingTarget (INT-277). Mark Fisher 2008-07-05 20:02:12 +00:00
  • 63c8c2a30f CafeDemo now demonstrates the <concurrency-interceptor/>. Mark Fisher 2008-07-05 18:53:46 +00:00
  • 6cb6347b82 Endpoint now throws MessageRejectedException when a MessageSelector rejects a Message. Mark Fisher 2008-07-05 18:39:11 +00:00
  • f6de774110 Now invokes the transformer in 'preSend' instead of 'postSend'. Mark Fisher 2008-07-05 16:56:05 +00:00
  • e1dca0ff9f ChannelInterceptor which allows transformation on send or receive from a channel Jonas Partner 2008-07-05 13:42:32 +00:00
  • 13109856f4 use static initialiser to set the custom security strategy Jonas Partner 2008-07-05 12:59:10 +00:00
  • bd5d71120f Added CallerRunsPolicy and threadNamePrefix for default MessageBus taskScheduler and ConcurrencyInterceptor. Mark Fisher 2008-07-04 23:32:27 +00:00
  • 71da892bcb Removed the Subscription class. Mark Fisher 2008-07-04 22:39:18 +00:00
  • 96b22fd01b Removing usage of the Subscription object, and resolved issue with 'auto-create' channels for SourceEndpoints (INT-235). Mark Fisher 2008-07-04 21:31:25 +00:00
  • 0aa00b969b Major refactoring of endpoint subscription, scheduling, and activation. This includes significant changes to the dispatcher implementations and the addition of endpoint "triggers" to drive polling and dispatching of messages. Also introduces an explicit PublishSubscribeChannel implementation and thereby removes support for the "publish-subscribe" attribute from channel elements in the namespace. Mark Fisher 2008-07-04 18:48:33 +00:00
  • 218da1aacf fixed warning Jonas Partner 2008-07-03 20:05:48 +00:00
  • 36343b4e1d Separated the OXM marshalling and unmarshalling transformer Added source and result factories Jonas Partner 2008-07-03 19:54:55 +00:00
  • 25bcd05293 Added tests for SimpleMessagingGateway. Mark Fisher 2008-07-03 17:47:07 +00:00
  • 7d8a6c0f84 Removed unnecessary lifecycle calls. Mark Fisher 2008-07-03 16:26:49 +00:00
  • acbde74691 Changed default receiveTimeout to 5000 ms (was -1 for indefinite blocking). Mark Fisher 2008-07-03 16:26:23 +00:00
  • aa1629b7cc Add cancellation of tasks in the stop() method. Mark Fisher 2008-07-03 15:50:29 +00:00
  • 27ac25ed33 Namespace support for endpoint interceptor security Jonas Partner 2008-07-03 14:21:08 +00:00
  • c59bbe767a Changed instance variable name to 'methodName' to match the 'setMethodName' method definition. Mark Fisher 2008-07-02 23:31:34 +00:00
  • d998095421 Removed 'maxMessagesPerTask' and 'receiveTimeout' properties from DispatcherPolicy and added those same properties to PollingDispatcherTask. The MessageDispatcher interface now extends the MessageTarget interface. Therefore, the 'dispatch(Message)' method has been replaced with 'send(Message)'. Mark Fisher 2008-07-02 22:56:00 +00:00
  • 7cefe22b96 changed MethodInvoking Soure and Targt to take a string via a a property methodName (fix for INT-272) Jonas Partner 2008-07-02 19:29:25 +00:00
  • ab858ee247 Refactored MessagingTaskScheduler to support cancellation and renamed 'TaskScheduler'. Mark Fisher 2008-07-02 18:42:33 +00:00
  • af8ae9780b Setting correlationId (if not already present) when processing aggregated Messages. Mark Fisher 2008-07-02 03:28:16 +00:00