org.jgroups.protocols.tom
public class ToaHeader extends Header
Modifier and Type | Field and Description |
---|---|
static byte |
DATA_MESSAGE |
static byte |
FINAL_MESSAGE |
static byte |
PROPOSE_MESSAGE |
static byte |
SINGLE_DESTINATION_MESSAGE |
Constructor and Description |
---|
ToaHeader() |
Modifier and Type | Method and Description |
---|---|
void |
addDestinations(Collection<Address> addresses) |
static ToaHeader |
createNewHeader(byte type,
MessageID messageID) |
static ToaHeader |
createSingleDestinationHeader() |
Collection<Address> |
getDestinations() |
MessageID |
getMessageID() |
Address |
getOrigin() |
long |
getSequencerNumber() |
byte |
getType() |
void |
readFrom(DataInput in)
Read the state of the current object (including superclasses) from instream
Note that the input stream must not be closed
|
void |
setSequencerNumber(long sequencerNumber) |
int |
size()
To be implemented by subclasses.
|
String |
toString() |
static String |
type2String(byte type) |
void |
writeTo(DataOutput out)
Write the entire state of the current object (including superclasses) to outstream.
|
public static final byte DATA_MESSAGE
public static final byte PROPOSE_MESSAGE
public static final byte FINAL_MESSAGE
public static final byte SINGLE_DESTINATION_MESSAGE
public MessageID getMessageID()
public Address getOrigin()
public void addDestinations(Collection<Address> addresses)
public Collection<Address> getDestinations()
public long getSequencerNumber()
public void setSequencerNumber(long sequencerNumber)
public byte getType()
public int size()
Header
public void writeTo(DataOutput out) throws Exception
Streamable
Exception
public void readFrom(DataInput in) throws Exception
Streamable
Exception
public static String type2String(byte type)
public static ToaHeader createSingleDestinationHeader()
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.