Package org.springframework.integration.amqp.support

Class BoundRabbitChannelAdvice

java.lang.Object

org.springframework.integration.amqp.support.BoundRabbitChannelAdvice

All Implemented Interfaces:

Advice, Interceptor, MethodInterceptor, HandleMessageAdvice

public class BoundRabbitChannelAdvice
extends Object
implements HandleMessageAdvice

An advice that causes all downstream RabbitOperations operations to be executed on the same channel, as long as there are no thread handoffs, since the channel is bound to the thread. The same RabbitOperations must be used in this and all downstream components. Typically, used with a splitter or some other mechanism that would cause multiple messages to be sent. Optionally waits for publisher confirms if the channel is so configured.

Since:

5.1

Author:

Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
BoundRabbitChannelAdvice(RabbitOperations operations)	Construct an instance that doesn't wait for confirms.
BoundRabbitChannelAdvice(RabbitOperations operations, Duration waitForConfirmsTimeout)	Construct an instance that waits for publisher confirms (if configured and waitForConfirmsTimeout is not null).

Method Summary

Modifier and Type	Method	Description
Object	invoke(MethodInvocation invocation)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BoundRabbitChannelAdvice

public BoundRabbitChannelAdvice(RabbitOperations operations)

Construct an instance that doesn't wait for confirms.

Parameters:

operations - the operations.

BoundRabbitChannelAdvice

public BoundRabbitChannelAdvice(RabbitOperations operations, @Nullable Duration waitForConfirmsTimeout)

Construct an instance that waits for publisher confirms (if configured and waitForConfirmsTimeout is not null).

Parameters:

operations - the operations.

waitForConfirmsTimeout - the timeout.

Method Details

invoke

public Object invoke(MethodInvocation invocation) throws Throwable

Specified by:

invoke in interface MethodInterceptor

Throws:

Throwable