org.jgroups.blocks

Class RequestCorrelator.Header

public static final class RequestCorrelator.Header extends Header implements Streamable

The header for RequestCorrelator messages

Field Summary
Stack	callStack Stack .
String	corrName The unique name of the associated `RequestCorrelator`
List	dest_mbrs Contains a list of members who should receive the request (others will drop).
long	id The id of this request to distinguish among other requests from the same `RequestCorrelator`
boolean	rsp_expected msg is synchronous if true
static byte	REQ
static byte	RSP
byte	type Type of header: request or reply

Constructor Summary
	Header() Used for externalization
	Header(byte type, long id, boolean rsp_expected, String name)

Method Summary
void	readExternal(ObjectInput in)
void	readFrom(DataInputStream in)
long	size()
String	toString()
void	writeExternal(ObjectOutput out)
void	writeTo(DataOutputStream out)

Field Detail

callStack

public Stack callStack

Stack

. Contains senders (e.g. P --> Q --> R)

corrName

public String corrName

The unique name of the associated RequestCorrelator

dest_mbrs

public List dest_mbrs

Contains a list of members who should receive the request (others will drop). Ignored if null

id

public long id

The id of this request to distinguish among other requests from the same RequestCorrelator

rsp_expected

public boolean rsp_expected

msg is synchronous if true

type

public byte type

Type of header: request or reply

Constructor Detail

Header

public Header(byte type, long id, boolean rsp_expected, String name)

Parameters: type type of header (REQ/RSP) id id of this header relative to ids of other requests originating from the same correlator rsp_expected whether it's a sync or async request name the name of the RequestCorrelator from which

Method Detail

readExternal

public void readExternal(ObjectInput in)

readFrom

public void readFrom(DataInputStream in)

size

public long size()

toString

public String toString()

writeExternal

public void writeExternal(ObjectOutput out)

writeTo

public void writeTo(DataOutputStream out)