spring-integration-amqp-exception-test

Test project for remote exception handling using Spring Integration AMQP. This implementation uses direct reply-to mechanism in order to decouple client and server.

Build and run

Build with mvn clean install and run MainServer (you can stop it with Enter key), then MainClient. The client will send a "valid" request first, then an invalid one that will raise an exception on the server. The exception will be wrapped in a response message and will be rethrown on the client side, just like a RPC.

Server config

• error-channel: this channel catches errors and forward them to the ErrorHandler.
• ErrorHandler: this service inspects the Message and wraps exception in a RuntimeExceptionHolder object (this is necessary due to the way MessagingGatewaySupport.doSendAndReceive works: if the response body is a Throwable, it is rethrown) and returns it as response with the original response headers (here we copy the original direct reply-to headers in the error message).

Client config

• ClientErrorInterceptor: this interceptor checks the response body type: if it's a RuntimeExceptionHolder, the original exception is unwrapped and thrown to the caller.

Open points

We are waiting for spring-rabbit 2.0.0 that will support direct reply-to with AsyncMessagingTemplate in order to achieve the same feature, but with non-blocking mode (see AMQP-616).