lumis.portal.cluster.multiserver

Class ClusterTransmissionHeader

java.lang.Object

org.jgroups.Header

lumis.portal.cluster.multiserver.ClusterTransmissionHeader

All Implemented Interfaces:

org.jgroups.Constructable<org.jgroups.Header>, org.jgroups.util.SizeStreamable, org.jgroups.util.Streamable

public class ClusterTransmissionHeader
extends org.jgroups.Header

Header used to store some control information about a IClusterTransmission. Some data available in the IClusterTransmission is also stored in this header to prevent the need to deserialize the message to read them.

Since:

4.1.0

Version:

$Revision: 23112 $ $Date: 2019-09-06 22:00:02 +0000 (Fri, 06 Sep 2019) $

Field Summary

Fields

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.
static short	MAGIC_ID

Fields inherited from class org.jgroups.Header

prot_id

Constructor Summary

Constructors

Constructor and Description
ClusterTransmissionHeader() Creates a header with default values.
ClusterTransmissionHeader(IClusterTransmission clusterTransmission) Creates a header initialized according to the given IClusterTransmission.

Method Summary

Modifier and Type	Method and Description
java.util.function.Supplier<? extends org.jgroups.Header>	create()
byte	getFlags() Returns the flags set in this header.
short	getMagicId()
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	readFrom(DataInput in)
int	serializedSize()
int	size()
String	toString()
void	writeTo(DataOutput out)

Methods inherited from class org.jgroups.Header

getProtId, setProtId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

FLAG_TOTAL_ORDER

public static final byte FLAG_TOTAL_ORDER

Bit used to indicate total order.

Since:

4.1.0

See Also:

getFlags(), Constant Field Values

FLAG_DURABLE

public static final byte FLAG_DURABLE

Bit used to indicate durable.

Since:

4.1.0

See Also:

getFlags(), Constant Field Values

MAGIC_ID

public static final short MAGIC_ID

See Also:

Constant Field Values

HEADER_NAME

public static final String HEADER_NAME

The name used to store this header.

Since:

4.1.0

See Also:

Constant Field Values

Constructor Detail

ClusterTransmissionHeader

public ClusterTransmissionHeader()

Creates a header with default values. Intended for use by deserialization process.

Since:

4.1.0

ClusterTransmissionHeader

public ClusterTransmissionHeader(IClusterTransmission clusterTransmission)

Creates a header initialized according to the given IClusterTransmission.

Parameters:

clusterTransmission - the cluster message.

Since:

4.1.0

Method Detail

getTransmissionId

public String getTransmissionId()

Returns the unique identifier of the transmission for which this header belongs.

Returns:

the unique identifier of the transmission.

Since:

4.1.0

getFlags

public byte getFlags()

Returns the flags set in this header.

Returns:

a value that is an OR combination of the active FLAG_* constants.

Since:

4.1.0

getTransmissionOrder

public long getTransmissionOrder()

Returns the transmission order generated for the corresponding transmission.

Returns:

the transmission order generated for the corresponding transmission.

Since:

4.1.0

size

public int size()

Overrides:

size in class org.jgroups.Header

toString

public String toString()

Overrides:

toString in class org.jgroups.Header

readFrom

public void readFrom(DataInput in)
              throws IOException,
                     ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeTo

public void writeTo(DataOutput out)
             throws IOException

Throws:

IOException

serializedSize

public int serializedSize()

create

public java.util.function.Supplier<? extends org.jgroups.Header> create()

getMagicId

public short getMagicId()

Specified by:

getMagicId in class org.jgroups.Header