org.springframework.amqp.rabbit.support

Interface PublisherCallbackChannel

All Superinterfaces:

java.lang.AutoCloseable, com.rabbitmq.client.Channel, com.rabbitmq.client.ShutdownNotifier

All Known Implementing Classes:

PublisherCallbackChannelImpl

public interface PublisherCallbackChannel
extends com.rabbitmq.client.Channel

Instances of this interface support a single listener being registered for publisher confirms with multiple channels, by adding context to the callbacks.

Since:

1.0.1

Author:

Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PublisherCallbackChannel.Listener Listeners implementing this interface can participate in publisher confirms received from multiple channels, by invoking addListener on each channel.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	RETURN_CORRELATION_KEY

Method Summary

Modifier and Type	Method and Description
void	addListener(PublisherCallbackChannel.Listener listener) Adds a PublisherCallbackChannel.Listener.
void	addPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm) Adds a pending confirmation to this channel's map.
java.util.Collection<PendingConfirm>	expire(PublisherCallbackChannel.Listener listener, long cutoffTime) Expire (remove) any PendingConfirms created before cutoffTime for the supplied listener and return them to the caller.
com.rabbitmq.client.Channel	getDelegate() Use this to invoke methods on the underlying rabbit client Channel that are not supported by this implementation.
int	getPendingConfirmsCount(PublisherCallbackChannel.Listener listener) Get the PendingConfirms count.

Methods inherited from interface com.rabbitmq.client.Channel

abort, abort, addConfirmListener, addConfirmListener, addReturnListener, addReturnListener, asyncCompletableRpc, asyncRpc, basicAck, basicCancel, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicGet, basicNack, basicPublish, basicPublish, basicPublish, basicQos, basicQos, basicQos, basicRecover, basicRecover, basicReject, clearConfirmListeners, clearReturnListeners, close, close, confirmSelect, consumerCount, exchangeBind, exchangeBind, exchangeBindNoWait, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclareNoWait, exchangeDeclareNoWait, exchangeDeclarePassive, exchangeDelete, exchangeDelete, exchangeDeleteNoWait, exchangeUnbind, exchangeUnbind, exchangeUnbindNoWait, getChannelNumber, getConnection, getDefaultConsumer, getNextPublishSeqNo, messageCount, queueBind, queueBind, queueBindNoWait, queueDeclare, queueDeclare, queueDeclareNoWait, queueDeclarePassive, queueDelete, queueDelete, queueDeleteNoWait, queuePurge, queueUnbind, queueUnbind, removeConfirmListener, removeReturnListener, rpc, setDefaultConsumer, txCommit, txRollback, txSelect, waitForConfirms, waitForConfirms, waitForConfirmsOrDie, waitForConfirmsOrDie

Methods inherited from interface com.rabbitmq.client.ShutdownNotifier

addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener

Field Detail

RETURN_CORRELATION_KEY

static final java.lang.String RETURN_CORRELATION_KEY

See Also:

Constant Field Values

Method Detail

addListener

void addListener(PublisherCallbackChannel.Listener listener)

Adds a PublisherCallbackChannel.Listener.

Parameters:

listener - The Listener.

expire

java.util.Collection<PendingConfirm> expire(PublisherCallbackChannel.Listener listener,
                                            long cutoffTime)

Expire (remove) any PendingConfirms created before cutoffTime for the supplied listener and return them to the caller.

Parameters:

listener - the listener.

cutoffTime - the time before which expired messages were created.

Returns:

the list of expired confirms.

getPendingConfirmsCount

int getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)

Get the PendingConfirms count.

Parameters:

listener - the listener.

Returns:

Count of the pending confirms.

addPendingConfirm

void addPendingConfirm(PublisherCallbackChannel.Listener listener,
                       long seq,
                       PendingConfirm pendingConfirm)

Adds a pending confirmation to this channel's map.

Parameters:

listener - The listener.

seq - The key to the map.

pendingConfirm - The PendingConfirm object.

getDelegate

com.rabbitmq.client.Channel getDelegate()

Use this to invoke methods on the underlying rabbit client Channel that are not supported by this implementation.

Returns:

The underlying rabbit client Channel.

Since:

1.4.