AMQChannel.BlockingRpcContinuation (RabbitMQ Java Client 4.12.0 API)

java.lang.Object
- com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation<T>

All Implemented Interfaces:

AMQChannel.RpcContinuation

Direct Known Subclasses:

AMQChannel.SimpleBlockingRpcContinuation

Enclosing class:

AMQChannel
```
public abstract static class AMQChannel.BlockingRpcContinuation<T>
extends Object
implements AMQChannel.RpcContinuation
```

Field Summary

Fields
Modifier and Type Field Description

BlockingValueOrException<T,ShutdownSignalException> _blocker

protected Method request

Constructor Summary

Constructors
Constructor Description

BlockingRpcContinuation()

BlockingRpcContinuation(Method request)

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`canHandleReply(AMQCommand command)`
`T`	`getReply()`
`T`	`getReply(int timeout)`
`void`	`handleCommand(AMQCommand command)`
`void`	`handleShutdownSignal(ShutdownSignalException signal)`
`abstract T`	`transformReply(AMQCommand command)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_blocker

public final BlockingValueOrException<T,ShutdownSignalException> _blocker

request
```
protected final Method request
```

Constructor Detail

BlockingRpcContinuation
```
public BlockingRpcContinuation()
```

BlockingRpcContinuation

public BlockingRpcContinuation(Method request)

Method Detail

handleCommand
```
public void handleCommand(AMQCommand command)
```
Specified by:

handleCommand in interface AMQChannel.RpcContinuation

handleShutdownSignal
```
public void handleShutdownSignal(ShutdownSignalException signal)
```
Specified by:

handleShutdownSignal in interface AMQChannel.RpcContinuation

getReply

public T getReply()
           throws ShutdownSignalException

Throws:: ShutdownSignalException

getReply

public T getReply(int timeout)
           throws ShutdownSignalException,
                  TimeoutException

Throws:: ShutdownSignalException; TimeoutException

canHandleReply
```
public boolean canHandleReply(AMQCommand command)
```
Specified by:

canHandleReply in interface AMQChannel.RpcContinuation

Returns:

true if the reply command can be handled for this request

transformReply

public abstract T transformReply(AMQCommand command)