Uses of Class
com.rabbitmq.client.ShutdownSignalException

Packages that use ShutdownSignalException

Package	Description
com.rabbitmq.client	The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.
com.rabbitmq.client.impl	Implementations of interfaces specified in the client API, and their supporting classes.
com.rabbitmq.client.impl.recovery	Implementation of connection and topology recovery.

Uses of ShutdownSignalException in com.rabbitmq.client

Subclasses of ShutdownSignalException in com.rabbitmq.client

Modifier and Type	Class	Description
class	AlreadyClosedException	Thrown when application tries to perform an action on connection/channel which was already closed

Methods in com.rabbitmq.client that return ShutdownSignalException

Modifier and Type	Method	Description
ShutdownSignalException	ShutdownNotifier.getCloseReason()	Get the shutdown reason object
ShutdownSignalException	RpcServer.mainloop()	Public API - main server loop.
ShutdownSignalException	ShutdownSignalException.sensibleClone()

Methods in com.rabbitmq.client with parameters of type ShutdownSignalException

Modifier and Type	Method	Description
void	Consumer.handleShutdownSignal(String consumerTag, ShutdownSignalException sig)	Called when either the channel or the underlying connection has been shut down.
void	DefaultConsumer.handleShutdownSignal(String consumerTag, ShutdownSignalException sig)	No-op implementation of Consumer.handleShutdownSignal(java.lang.String, com.rabbitmq.client.ShutdownSignalException).
void	QueueingConsumer.handleShutdownSignal(String consumerTag, ShutdownSignalException sig)	Deprecated.
void	ShutdownListener.shutdownCompleted(ShutdownSignalException cause)

Methods in com.rabbitmq.client that throw ShutdownSignalException

Modifier and Type	Method	Description
RpcClient.Response	RpcClient.doCall(AMQP.BasicProperties props, byte[] message, int timeout)
Map<String,Object>	RpcClient.mapCall(Object[] keyValuePairs)	Perform an AMQP wire-protocol-table based RPC roundtrip, first constructing the table from an array of alternating keys (in even-numbered elements, starting at zero) and values (in odd-numbered elements, starting at one) Restrictions on value arguments apply as in RpcClient.mapCall(Map).
Map<String,Object>	RpcClient.mapCall(Map<String,Object> message)	Perform an AMQP wire-protocol-table based RPC roundtrip There are some restrictions on the values appearing in the table: they must be of type String, LongString, Integer, BigDecimal, Date, or (recursively) a Map of the enclosing type.
QueueingConsumer.Delivery	QueueingConsumer.nextDelivery()	Deprecated. Main application-side API: wait for the next message delivery and return it.
QueueingConsumer.Delivery	QueueingConsumer.nextDelivery(long timeout)	Deprecated. Main application-side API: wait for the next message delivery and return it.
byte[]	RpcClient.primitiveCall(byte[] message)	Perform a simple byte-array-based RPC roundtrip.
byte[]	RpcClient.primitiveCall(AMQP.BasicProperties props, byte[] message)
byte[]	RpcClient.primitiveCall(AMQP.BasicProperties props, byte[] message, int timeout)
RpcClient.Response	RpcClient.responseCall(byte[] message)	Perform a simple byte-array-based RPC roundtrip Useful if you need to get at more than just the body of the message
RpcClient.Response	RpcClient.responseCall(byte[] message, int timeout)	Perform a simple byte-array-based RPC roundtrip Useful if you need to get at more than just the body of the message
String	RpcClient.stringCall(String message)	Perform a simple string-based RPC roundtrip.

Constructors in com.rabbitmq.client with parameters of type ShutdownSignalException

Constructor	Description
AlreadyClosedException(ShutdownSignalException sse)
AlreadyClosedException(ShutdownSignalException sse, Throwable cause)

Uses of ShutdownSignalException in com.rabbitmq.client.impl

Fields in com.rabbitmq.client.impl with type parameters of type ShutdownSignalException

Modifier and Type	Field	Description
BlockingValueOrException<T,ShutdownSignalException>	AMQChannel.BlockingRpcContinuation._blocker

Methods in com.rabbitmq.client.impl that return ShutdownSignalException

Modifier and Type	Method	Description
ShutdownSignalException	ShutdownNotifierComponent.getCloseReason()
ShutdownSignalException	AMQConnection.shutdown(Method reason, boolean initiatedByApplication, Throwable cause, boolean notifyRpc)	Protected API - causes all attached channels to terminate (shutdown) with a ShutdownSignal built from the argument, and stops this connection from accepting further work from the application.

Methods in com.rabbitmq.client.impl with parameters of type ShutdownSignalException

Modifier and Type	Method	Description
void	AMQChannel.BlockingRpcContinuation.handleShutdownSignal(ShutdownSignalException signal)
void	AMQChannel.RpcContinuation.handleShutdownSignal(ShutdownSignalException signal)
void	ChannelManager.handleSignal(ShutdownSignalException signal)	Handle shutdown.
void	AMQChannel.notifyOutstandingRpc(ShutdownSignalException signal)
void	AMQChannel.processShutdownSignal(ShutdownSignalException signal, boolean ignoreClosed, boolean notifyRpc)	Protected API - respond, in the driver thread, to a ShutdownSignalException.
void	ChannelN.processShutdownSignal(ShutdownSignalException signal, boolean ignoreClosed, boolean notifyRpc)	Protected API - overridden to quiesce consumer work and broadcast the signal to all consumers after calling the superclass's method.
boolean	ShutdownNotifierComponent.setShutdownCauseIfOpen(ShutdownSignalException sse)	Internal: this is the means of registering shutdown.
static IOException	AMQChannel.wrap(ShutdownSignalException ex)	Placeholder until we address bug 15786 (implementing a proper exception hierarchy).
static IOException	AMQChannel.wrap(ShutdownSignalException ex, String message)

Methods in com.rabbitmq.client.impl that throw ShutdownSignalException

Modifier and Type	Method	Description
T	AMQChannel.BlockingRpcContinuation.getReply()
T	AMQChannel.BlockingRpcContinuation.getReply(int timeout)
AMQCommand	AMQChannel.rpc(Method m)	Protected API - sends a Method to the broker and waits for the next in-bound Command from the broker: only for use from non-connection-MainLoop threads!
AMQCommand	AMQChannel.rpc(Method m, int timeout)

Uses of ShutdownSignalException in com.rabbitmq.client.impl.recovery

Methods in com.rabbitmq.client.impl.recovery that return ShutdownSignalException

Modifier and Type	Method	Description
ShutdownSignalException	AutorecoveringChannel.getCloseReason()
ShutdownSignalException	AutorecoveringConnection.getCloseReason()

Methods in com.rabbitmq.client.impl.recovery with parameters of type ShutdownSignalException

Modifier and Type	Method	Description
void	RecoveryCanBeginListener.recoveryCanBegin(ShutdownSignalException cause)
protected boolean	AutorecoveringConnection.shouldTriggerConnectionRecovery(ShutdownSignalException cause)