public static abstract class

AMQChannel.BlockingRpcContinuation

extends Object
implements AMQChannel.RpcContinuation
java.lang.Object
   ↳ com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation<T>
Known Direct Subclasses

Summary

Fields
public final BlockingValueOrException<T, ShutdownSignalException> _blocker
Public Constructors
AMQChannel.BlockingRpcContinuation()
Public Methods
T getReply(int timeout)
T getReply()
void handleCommand(AMQCommand command)
void handleShutdownSignal(ShutdownSignalException signal)
abstract T transformReply(AMQCommand command)
[Expand]
Inherited Methods
From class java.lang.Object
From interface com.rabbitmq.client.impl.AMQChannel.RpcContinuation

Fields

public final BlockingValueOrException<T, ShutdownSignalException> _blocker

Public Constructors

public AMQChannel.BlockingRpcContinuation ()

Public Methods

public T getReply (int timeout)

Throws
ShutdownSignalException
TimeoutException

public T getReply ()

Throws
ShutdownSignalException

public void handleCommand (AMQCommand command)

public void handleShutdownSignal (ShutdownSignalException signal)

public abstract T transformReply (AMQCommand command)