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 closedMethods 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 TypeMethodDescriptionvoid
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
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.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 with type parameters of type ShutdownSignalExceptionMethods 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.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 TypeMethodDescriptionvoid
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 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) void
RpcContinuationRpcWrapper.shutdown
(ShutdownSignalException signal) void
RpcWrapper.shutdown
(ShutdownSignalException signal) 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 ShutdownSignalExceptionModifier and TypeMethodDescriptionvoid
ConnectionParams.setConnectionRecoveryTriggeringCondition
(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition) Methods in com.rabbitmq.client.impl that throw ShutdownSignalException -
Uses of ShutdownSignalException in com.rabbitmq.client.impl.recovery
Fields in com.rabbitmq.client.impl.recovery with type parameters of type ShutdownSignalExceptionModifier and TypeFieldDescriptionstatic 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)