diff --git a/spring-integration-reference/src/configuration.xml b/spring-integration-reference/src/configuration.xml index bc6a2902f4..f1bbe7f7b1 100644 --- a/spring-integration-reference/src/configuration.xml +++ b/spring-integration-reference/src/configuration.xml @@ -240,9 +240,54 @@ selector="exampleSelector"/>]]> - Another important configuration option for message endpoints is the concurrency interceptor. Each - endpoint is capable of managing a thread pool, and the concurrency settings you provide for that - pool's core and max size can make a substantial difference in how the endpoint performs under load. + Another important configuration option for message endpoints is the inclusion of + EndpointInterceptors. The interface is defined as follows: + message); + + boolean aroundSend(Message message, MessageTarget endpoint); + + void postSend(Message message, boolean result); +}]]> + There is also an EndpointInterceptorAdapter that provides no-op methods for convenience + when subclassing. Within an endpoint configuration, interceptors can be added within + the <interceptors> sub-element. It accepts either "ref" elements or inner "beans": + + + + + + +]]> + + + Spring Integration provides a TransactionInterceptor and namespace + support with the <transaction-interceptor> element. The attributes for this element + should be familiar to anyone who has experience with Spring's Transaction management: + + + + + +]]> + + + Spring Integration also provides a ConcurrencyInterceptor. By applying this, an endpoint becomes capable of + managing a thread pool, and the concurrency settings you provide for that pool's core size, max size, + and queue capacity can make a substantial difference in how the endpoint performs under load. These settings are available per-endpoint since the performance characteristics of an endpoint's handler or target is one of the major factors to consider (the other major factor being the expected volume on the channel to which the endpoint subscribes). To enable concurrency for an endpoint that is configured with the