Uses of Class
com.rabbitmq.client.ShutdownSignalException
Packages that use ShutdownSignalException
Package
Description
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
Implementations of interfaces specified in the client API, and their supporting classes.
Implementation of connection and topology recovery.
-
Uses of ShutdownSignalException in com.rabbitmq.client
Subclasses of ShutdownSignalException in com.rabbitmq.clientModifier and TypeClassDescriptionclass
Thrown when application tries to perform an action on connection/channel which was already closedFields in com.rabbitmq.client declared as ShutdownSignalExceptionModifier and TypeFieldDescriptionprivate ShutdownSignalException
RpcServer.DefaultRpcConsumer._shutdown
Fields in com.rabbitmq.client with type parameters of type ShutdownSignalExceptionModifier and TypeFieldDescriptionprivate Predicate
<ShutdownSignalException> ConnectionFactory.connectionRecoveryTriggeringCondition
Condition to trigger automatic connection recovery.Methods in com.rabbitmq.client that return ShutdownSignalExceptionModifier and TypeMethodDescriptionShutdownNotifier.getCloseReason()
Get the shutdown reason objectRpcServer.mainloop()
Public API - main server loop.ShutdownSignalException.sensibleClone()
Methods in com.rabbitmq.client with parameters of type ShutdownSignalExceptionModifier and TypeMethodDescriptionprivate 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 ofConsumer.handleShutdownSignal(java.lang.String, com.rabbitmq.client.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 ShutdownSignalExceptionModifier and TypeMethodDescriptionvoid
ConnectionFactory.setConnectionRecoveryTriggeringCondition
(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition) Allows to decide on automatic connection recovery is triggered.Methods in com.rabbitmq.client that throw ShutdownSignalExceptionModifier and TypeMethodDescriptionRpcClient.doCall
(AMQP.BasicProperties props, byte[] message, int timeout) 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 inRpcClient.mapCall(Map)
.Perform an AMQP wire-protocol-table based RPC roundtrip
There are some restrictions on the values appearing in the table:
they must be of typeString
,LongString
,Integer
,BigDecimal
,Date
, or (recursively) aMap
of the enclosing type.RpcServer.DefaultRpcConsumer.nextDelivery()
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.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 messageRpcClient.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 messageRpcClient.stringCall
(String message) Perform a simple string-based RPC roundtrip.Constructors in com.rabbitmq.client with parameters of type ShutdownSignalExceptionModifierConstructorDescriptionAlreadyClosedException
(ShutdownSignalException sse, Throwable cause) -
Uses of ShutdownSignalException in com.rabbitmq.client.impl
Fields in com.rabbitmq.client.impl declared as ShutdownSignalExceptionModifier and TypeFieldDescriptionprivate 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 ShutdownSignalExceptionModifier and TypeFieldDescriptionAMQChannel.BlockingRpcContinuation._blocker
private Predicate
<ShutdownSignalException> ConnectionParams.connectionRecoveryTriggeringCondition
Methods in com.rabbitmq.client.impl that return ShutdownSignalExceptionModifier and TypeMethodDescriptionShutdownNotifierComponent.getCloseReason()
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 ShutdownSignalExceptionMethods in com.rabbitmq.client.impl with parameters of type ShutdownSignalExceptionModifier and TypeMethodDescriptionprivate 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) 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 aShutdownSignalException
.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 readystatic 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 ShutdownSignalExceptionModifier and TypeMethodDescriptionvoid
ConnectionParams.setConnectionRecoveryTriggeringCondition
(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition) Methods in com.rabbitmq.client.impl that throw ShutdownSignalExceptionModifier and TypeMethodDescriptionAMQChannel.BlockingRpcContinuation.getReply()
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) Protected API - sends aMethod
to the broker and waits for the next in-bound Command from the broker: only for use from non-connection-MainLoop threads!Constructors in com.rabbitmq.client.impl with parameters of type ShutdownSignalException -
Uses of ShutdownSignalException in com.rabbitmq.client.impl.recovery
Fields in com.rabbitmq.client.impl.recovery with type parameters of type ShutdownSignalExceptionModifier and TypeFieldDescriptionprivate final Predicate
<ShutdownSignalException> AutorecoveringConnection.connectionRecoveryTriggeringCondition
static final Predicate
<ShutdownSignalException> AutorecoveringConnection.DEFAULT_CONNECTION_RECOVERY_TRIGGERING_CONDITION
Methods in com.rabbitmq.client.impl.recovery that return ShutdownSignalExceptionModifier and TypeMethodDescriptionAutorecoveringChannel.getCloseReason()
AutorecoveringConnection.getCloseReason()
Methods in com.rabbitmq.client.impl.recovery with parameters of type ShutdownSignalExceptionModifier and TypeMethodDescriptionvoid
RecoveryCanBeginListener.recoveryCanBegin
(ShutdownSignalException cause) protected boolean
AutorecoveringConnection.shouldTriggerConnectionRecovery
(ShutdownSignalException cause)