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() |
Supplier<? extends Header> |
create()
Creates an instance of the class implementing this interface
|
short |
getMagicId()
Returns the magic-ID.
|
void |
readFrom(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 |
serializedSize()
Returns the size (in bytes) of the marshalled object
|
String |
toString() |
void |
writeTo(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 short getMagicId()
Header
getMagicId
in class Header
public Supplier<? extends Header> create()
Constructable
public long requestId()
public boolean rspExpected()
public short corrId()
public void writeTo(DataOutput out) throws Exception
Streamable
Exception
public void readFrom(DataInput in) throws Exception
Streamable
Exception
public int serializedSize()
SizeStreamable
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.