org.springframework.amqp.rabbit.support

Interface PublisherCallbackChannel

All Superinterfaces:

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.

Methods inherited from interface com.rabbitmq.client.Channel

abort, abort, addConfirmListener, addFlowListener, addReturnListener, asyncRpc, basicAck, basicCancel, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicGet, basicNack, basicPublish, basicPublish, basicPublish, basicQos, basicQos, basicQos, basicRecover, basicRecover, basicReject, clearConfirmListeners, clearFlowListeners, 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, flowBlocked, getChannelNumber, getConnection, getDefaultConsumer, getNextPublishSeqNo, messageCount, queueBind, queueBind, queueBindNoWait, queueDeclare, queueDeclare, queueDeclareNoWait, queueDeclarePassive, queueDelete, queueDelete, queueDeleteNoWait, queuePurge, queueUnbind, queueUnbind, removeConfirmListener, removeFlowListener, 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.

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.