public static class RequestCorrelator.Header extends Header
Modifier and Type | Field and Description |
---|---|
short |
corrId
The unique ID of the associated RequestCorrelator
|
long |
id
The id of this request to distinguish among other requests from the same RequestCorrelator
|
static byte |
REQ |
static byte |
RSP |
boolean |
rsp_expected
msg is synchronous if true
|
byte |
type
Type of header: request or reply
|
Constructor and Description |
---|
RequestCorrelator.Header()
Used for externalization
|
RequestCorrelator.Header(byte type,
long id,
boolean rsp_expected,
short corr_id) |
Modifier and Type | Method and Description |
---|---|
void |
readFrom(DataInputStream in)
Read the state of the current object (including superclasses) from instream
Note that the input stream must not be closed
|
int |
size()
To be implemented by subclasses.
|
String |
toString() |
void |
writeTo(DataOutputStream out)
Write the entire state of the current object (including superclasses) to outstream.
|
public static final byte REQ
public static final byte RSP
public byte type
public long id
public boolean rsp_expected
public short corrId
public RequestCorrelator.Header()
public RequestCorrelator.Header(byte type, long id, boolean rsp_expected, short corr_id)
type
- type of header (REQ/RSP)id
- id of this header relative to ids of other requests
originating from the same correlatorrsp_expected
- whether it's a sync or async requestcorr_id
- The ID of the RequestCorrelator from whichpublic void writeTo(DataOutputStream out) throws IOException
Streamable
IOException
public void readFrom(DataInputStream in) throws IOException, IllegalAccessException, InstantiationException
Streamable
public int size()
Header
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.