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

Classes in com.rabbitmq.client that implement interfaces with type arguments of type ShutdownSignalException

Modifier and Type	Class	Description
class	ShutdownSignalException	Encapsulates a shutdown condition for a connection to an AMQP broker.

Fields in com.rabbitmq.client declared as ShutdownSignalException

Modifier and Type	Field	Description
private ShutdownSignalException	RpcServer.DefaultRpcConsumer._shutdown

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

Modifier and Type	Field	Description
private Predicate<ShutdownSignalException>	ConnectionFactory.connectionRecoveryTriggeringCondition	Condition to trigger automatic connection recovery.

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
private static String	AlreadyClosedException.composeMessagePrefix(ShutdownSignalException sse)
void	Consumer.handleShutdownSignal(String consumerTag, ShutdownSignalException sig)	Called when either the channel or the underlying connection has been shut down.
void	ConsumerShutdownSignalCallback.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(String, ShutdownSignalException).
void	RpcServer.DefaultRpcConsumer.handleShutdownSignal(String consumerTag, ShutdownSignalException sig)
void	ShutdownListener.shutdownCompleted(ShutdownSignalException cause)

Method parameters in com.rabbitmq.client with type arguments of type ShutdownSignalException

Modifier and Type	Method	Description
void	ConnectionFactory.setConnectionRecoveryTriggeringCondition(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition)	Allows to decide on automatic connection recovery is triggered.

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.
Delivery	RpcServer.DefaultRpcConsumer.nextDelivery()
Delivery	RpcServer.RpcConsumer.nextDelivery()
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

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

Uses of ShutdownSignalException in com.rabbitmq.client.impl

Fields in com.rabbitmq.client.impl declared as ShutdownSignalException

Modifier and Type	Field	Description
private final ShutdownSignalException	AMQConnection.SocketCloseWait.cause
private ShutdownSignalException	ShutdownNotifierComponent.shutdownCause	When this value is null, the component is in an "open" state.
private ShutdownSignalException	ConsumerDispatcher.shutdownSignal

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

Modifier and Type	Field	Description
final BlockingValueOrException<T, ShutdownSignalException>	AMQChannel.BlockingRpcContinuation._blocker
private Predicate<ShutdownSignalException>	ConnectionParams.connectionRecoveryTriggeringCondition

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.
private ShutdownSignalException	AMQConnection.startShutdown(Method reason, boolean initiatedByApplication, Throwable cause, boolean notifyRpc)

Methods in com.rabbitmq.client.impl that return types with arguments of type ShutdownSignalException

Modifier and Type	Method	Description
Predicate<ShutdownSignalException>	ConnectionParams.getConnectionRecoveryTriggeringCondition()

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

Modifier and Type	Method	Description
private void	ChannelN.broadcastShutdownSignal(ShutdownSignalException signal)	Sends a ShutdownSignal to all active consumers.
private void	AMQConnection.finishShutdown(ShutdownSignalException sse)
void	AMQChannel.BlockingRpcContinuation.handleShutdownSignal(ShutdownSignalException signal)
void	AMQChannel.RpcContinuation.handleShutdownSignal(ShutdownSignalException signal)
CountDownLatch	ConsumerDispatcher.handleShutdownSignal(Map<String,Consumer> consumers, ShutdownSignalException signal)
void	ChannelManager.handleSignal(ShutdownSignalException signal)	Handle shutdown.
private void	ConsumerDispatcher.notifyConsumerOfShutdown(String consumerTag, Consumer consumer, ShutdownSignalException signal)
private void	ConsumerDispatcher.notifyConsumersOfShutdown(Map<String,Consumer> consumers, ShutdownSignalException signal)
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.
void	CompletableFutureRpcWrapper.shutdown(ShutdownSignalException signal)
private void	ConsumerDispatcher.shutdown(ShutdownSignalException signal)
void	RpcContinuationRpcWrapper.shutdown(ShutdownSignalException signal)
void	RpcWrapper.shutdown(ShutdownSignalException signal)
private void	ChannelN.startProcessShutdownSignal(ShutdownSignalException signal, boolean ignoreClosed, boolean notifyRpc)	Start to shutdown -- defer rest of processing until ready
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)

Method parameters in com.rabbitmq.client.impl with type arguments of type ShutdownSignalException

Modifier and Type	Method	Description
void	ConnectionParams.setConnectionRecoveryTriggeringCondition(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition)

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

Modifier and Type	Method	Description
T	AMQChannel.BlockingRpcContinuation.getReply()
T	AMQChannel.BlockingRpcContinuation.getReply(int timeout)
private CompletableFuture<Command>	AMQChannel.privateAsyncRpc(Method m)
private AMQCommand	AMQChannel.privateRpc(Method m)
private AMQCommand	AMQChannel.privateRpc(Method m, 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)

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

Modifier	Constructor	Description
	SocketCloseWait(ShutdownSignalException sse)

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

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

Modifier and Type	Field	Description
private final Predicate<ShutdownSignalException>	AutorecoveringConnection.connectionRecoveryTriggeringCondition
static final Predicate<ShutdownSignalException>	AutorecoveringConnection.DEFAULT_CONNECTION_RECOVERY_TRIGGERING_CONDITION

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)