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 |
---|---|
Supplier<? extends Header> |
create()
Creates an instance of the class implementing this interface
|
static ToaHeader |
createSingleDestinationHeader(MessageID messageID) |
short |
getMagicId()
Returns the magic-ID.
|
MessageID |
getMessageID() |
long |
getSequencerNumber() |
byte |
getType() |
long |
getViewId() |
static ToaHeader |
newDataMessageHeader(MessageID messageID,
long viewId) |
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
|
int |
serializedSize()
Returns the size (in bytes) of the marshalled object
|
ToaHeader |
setSequencerNumber(long sequencerNumber) |
String |
toString() |
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 short getMagicId()
Header
getMagicId
in class Header
public Supplier<? extends Header> create()
Constructable
public MessageID getMessageID()
public long getSequencerNumber()
public ToaHeader setSequencerNumber(long sequencerNumber)
public byte getType()
public int serializedSize()
SizeStreamable
public void writeTo(DataOutput out) throws Exception
Streamable
Exception
public void readFrom(DataInput in) throws Exception
Streamable
Exception
public static ToaHeader newProposeMessageHeader(MessageID messageID, long sequencerNumber)
public static ToaHeader newFinalMessageHeader(MessageID messageID, long sequenceNumber)
public static ToaHeader createSingleDestinationHeader(MessageID messageID)
public long getViewId()
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.