public class ClusterTransmissionHeader
extends org.jgroups.Header
implements org.jgroups.util.Streamable
IClusterTransmission
.
Some data available in the IClusterTransmission
is also stored in this
header to prevent the need to deserialize the message to read them.Modifier and Type | Field and Description |
---|---|
static byte |
FLAG_DURABLE
Bit used to indicate durable.
|
static byte |
FLAG_TOTAL_ORDER
Bit used to indicate total order.
|
static String |
HEADER_NAME
The name used to store this header.
|
Constructor and Description |
---|
ClusterTransmissionHeader()
Creates a header with default values.
|
ClusterTransmissionHeader(IClusterTransmission clusterTransmission)
Creates a header initialized according to the given
IClusterTransmission . |
Modifier and Type | Method and Description |
---|---|
byte |
getFlags()
Returns the flags set in this header.
|
String |
getTransmissionId()
Returns the unique identifier of the transmission for which this header belongs.
|
long |
getTransmissionOrder()
Returns the transmission order generated for the corresponding transmission.
|
void |
readExternal(ObjectInput in) |
void |
readFrom(DataInputStream in) |
int |
size() |
String |
toString() |
void |
writeExternal(ObjectOutput out) |
void |
writeTo(DataOutputStream out) |
public static final byte FLAG_TOTAL_ORDER
getFlags()
,
Constant Field Valuespublic static final byte FLAG_DURABLE
getFlags()
,
Constant Field Valuespublic static final String HEADER_NAME
public ClusterTransmissionHeader()
public ClusterTransmissionHeader(IClusterTransmission clusterTransmission)
IClusterTransmission
.clusterTransmission
- the cluster message.public String getTransmissionId()
public byte getFlags()
public long getTransmissionOrder()
public int size()
size
in class org.jgroups.Header
public String toString()
toString
in class org.jgroups.Header
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
IOException
public void readFrom(DataInputStream in) throws IOException, IllegalAccessException, InstantiationException
readFrom
in interface org.jgroups.util.Streamable
IOException
IllegalAccessException
InstantiationException
public void writeTo(DataOutputStream out) throws IOException
writeTo
in interface org.jgroups.util.Streamable
IOException
LumisXP 12.0.0.190809 - Copyright © 2006–2019 Lumis EIP Tecnologia da Informação LTDA. All Rights Reserved.