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 |
---|---|
static ToaHeader |
createSingleDestinationHeader(MessageID messageID) |
Collection<Address> |
getDestinations() |
MessageID |
getMessageID() |
long |
getSequencerNumber() |
byte |
getType() |
static ToaHeader |
newDataMessageHeader(MessageID messageID,
Collection<Address> destinations) |
static ToaHeader |
newFinalMessageHeader(MessageID messageID,
long sequenceNumber) |
static ToaHeader |
newProposeMessageHeader(MessageID messageID,
long sequencerNumber) |
void |
readFrom(DataInput in)
Read the state of the current object (including superclasses) from instream
Note that the input stream must not be closed
|
ToaHeader |
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 Collection<Address> getDestinations()
public long getSequencerNumber()
public ToaHeader 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 newDataMessageHeader(MessageID messageID, Collection<Address> destinations)
public static ToaHeader newProposeMessageHeader(MessageID messageID, long sequencerNumber)
public static ToaHeader newFinalMessageHeader(MessageID messageID, long sequenceNumber)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.