org.jgroups.blocks
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(java.io.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.
|
java.lang.String |
toString() |
void |
writeTo(java.io.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(java.io.DataOutputStream out) throws java.io.IOException
Streamable
java.io.IOException
public void readFrom(java.io.DataInputStream in) throws java.io.IOException, java.lang.IllegalAccessException, java.lang.InstantiationException
Streamable
java.io.IOException
java.lang.IllegalAccessException
java.lang.InstantiationException
public int size()
Header
Copyright © 1998-2009 Bela Ban / Red Hat. All Rights Reserved.