public class RpcConnectionFlowControl
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static int |
FLUSH_CMD_LENGTH
Length in bytes of a flush command when marshaled.
|
static java.lang.String |
TRACE_PREFIX |
Modifier | Constructor and Description |
---|---|
protected |
RpcConnectionFlowControl() |
Modifier and Type | Method and Description |
---|---|
RpcPacket |
respondToFlush1(java.util.Map<java.lang.String,java.lang.Object> resultsMap)
Construct a flush2 response to the passed-in flush1 packet.
|
RpcPacket |
respondToFlush1(RpcPacket flush1)
Construct a flush2 response to the passed-in flush1 packet.
|
public static final java.lang.String TRACE_PREFIX
public static final int FLUSH_CMD_LENGTH
public RpcPacket respondToFlush1(RpcPacket flush1)
flush1
- flush1public RpcPacket respondToFlush1(java.util.Map<java.lang.String,java.lang.Object> resultsMap)
resultsMap
- resultsMap