public static class RequestCorrelator.Header extends Header
Modifier and Type | Field and Description |
---|---|
short |
corrId
The unique ID of the associated RequestCorrelator
|
static byte |
EXC_RSP |
static byte |
REQ |
long |
req_id
The request id (unique for each blocking request), 0 means no response is expected
|
static byte |
RSP |
byte |
type
Type of header: request or reply
|
Constructor and Description |
---|
Header() |
Header(byte type,
long req_id,
short corr_id) |
Modifier and Type | Method and Description |
---|---|
short |
corrId() |
void |
readFrom(java.io.DataInput in)
Read the state of the current object (including superclasses) from instream
Note that the input stream must not be closed
|
long |
requestId() |
RequestCorrelator.Header |
requestId(long req_id) |
boolean |
rspExpected() |
int |
size()
To be implemented by subclasses.
|
java.lang.String |
toString() |
void |
writeTo(java.io.DataOutput out)
Write the entire state of the current object (including superclasses) to outstream.
|
public static final byte REQ
public static final byte RSP
public static final byte EXC_RSP
public byte type
public long req_id
public short corrId
public Header()
public Header(byte type, long req_id, short corr_id)
type
- type of header (REQ/RSP)req_id
- id of this header relative to ids of other requests originating from the same correlatorcorr_id
- The ID of the RequestCorrelator from whichpublic RequestCorrelator.Header requestId(long req_id)
public long requestId()
public boolean rspExpected()
public short corrId()
public void writeTo(java.io.DataOutput out) throws java.lang.Exception
Streamable
java.lang.Exception
public void readFrom(java.io.DataInput in) throws java.lang.Exception
Streamable
java.lang.Exception
public int size()
Header
Copyright © 1998-2020 Red Hat. All Rights Reserved.