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 closedFields 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 java.util.function.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 objectShutdownSignalException
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 java.lang.String
AlreadyClosedException. composeMessagePrefix(ShutdownSignalException sse)
void
Consumer. handleShutdownSignal(java.lang.String consumerTag, ShutdownSignalException sig)
Called when either the channel or the underlying connection has been shut down.void
ConsumerShutdownSignalCallback. handleShutdownSignal(java.lang.String consumerTag, ShutdownSignalException sig)
Called when either the channel or the underlying connection has been shut down.void
DefaultConsumer. handleShutdownSignal(java.lang.String consumerTag, ShutdownSignalException sig)
No-op implementation ofConsumer.handleShutdownSignal(java.lang.String, com.rabbitmq.client.ShutdownSignalException)
.void
RpcServer.DefaultRpcConsumer. handleShutdownSignal(java.lang.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(java.util.function.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)
java.util.Map<java.lang.String,java.lang.Object>
RpcClient. mapCall(java.lang.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 inRpcClient.mapCall(Map)
.java.util.Map<java.lang.String,java.lang.Object>
RpcClient. mapCall(java.util.Map<java.lang.String,java.lang.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 typeString
,LongString
,Integer
,BigDecimal
,Date
, or (recursively) aMap
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 messageRpcClient.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 messagejava.lang.String
RpcClient. stringCall(java.lang.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, java.lang.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 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 BlockingValueOrException<T,ShutdownSignalException>
AMQChannel.BlockingRpcContinuation. _blocker
private java.util.function.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, java.lang.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, java.lang.Throwable cause, boolean notifyRpc)
Methods in com.rabbitmq.client.impl that return types with arguments of type ShutdownSignalException Modifier and Type Method Description java.util.function.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)
java.util.concurrent.CountDownLatch
ConsumerDispatcher. handleShutdownSignal(java.util.Map<java.lang.String,Consumer> consumers, ShutdownSignalException signal)
void
ChannelManager. handleSignal(ShutdownSignalException signal)
Handle shutdown.private void
ConsumerDispatcher. notifyConsumerOfShutdown(java.lang.String consumerTag, Consumer consumer, ShutdownSignalException signal)
private void
ConsumerDispatcher. notifyConsumersOfShutdown(java.util.Map<java.lang.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 java.io.IOException
AMQChannel. wrap(ShutdownSignalException ex)
Placeholder until we address bug 15786 (implementing a proper exception hierarchy).static java.io.IOException
AMQChannel. wrap(ShutdownSignalException ex, java.lang.String message)
Method parameters in com.rabbitmq.client.impl with type arguments of type ShutdownSignalException Modifier and Type Method Description void
ConnectionParams. setConnectionRecoveryTriggeringCondition(java.util.function.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 java.util.concurrent.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 aMethod
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 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 java.util.function.Predicate<ShutdownSignalException>
AutorecoveringConnection. connectionRecoveryTriggeringCondition
static java.util.function.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)
-