com.bigdata.ha.msg

Class HASendState

java.lang.Object

com.bigdata.ha.msg.HASendState

All Implemented Interfaces:

IHASendState, Externalizable, Serializable

public class HASendState
extends Object
implements IHASendState, Externalizable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HASendState() De-serialization constructor.
HASendState(long messageId, UUID originalSenderId, UUID senderId, long token, int replicationFactor)

Method Summary

Methods

Modifier and Type	Method and Description
static IHASendState	decode(byte[] a) Decode the value returned by getMarker().
boolean	equals(Object obj)
byte[]	getMarker() A byte[] marker that must prefix the message payload, needed to skip stale data from failed read tasks.
long	getMessageId() A unique (one-up) message sequence identifier for the messages from the sender.
UUID	getOriginalSenderId() The UUID of the originating service.
long	getQuorumToken() The current quorum token on the sender.
int	getReplicationFactor() The current replication factor on the sender.
UUID	getSenderId() The UUID of the sending service.
int	hashCode()
void	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HASendState

public HASendState()

De-serialization constructor.

HASendState

public HASendState(long messageId,
           UUID originalSenderId,
           UUID senderId,
           long token,
           int replicationFactor)

Method Detail

getMessageId

public long getMessageId()

Description copied from interface: IHASendState

A unique (one-up) message sequence identifier for the messages from the sender. This identifier may be used to verify that the bytes available from the replication stream are associated with the designed payload.

Specified by:

getMessageId in interface IHASendState

getOriginalSenderId

public UUID getOriginalSenderId()

Description copied from interface: IHASendState

The UUID of the originating service. This may be used to verify that a message was sourced the expected quorum leader.

Specified by:

getOriginalSenderId in interface IHASendState

getSenderId

public UUID getSenderId()

Description copied from interface: IHASendState

The UUID of the sending service. This may be used to verify that a message was sourced the expected upstream service.

Specified by:

getSenderId in interface IHASendState

getQuorumToken

public long getQuorumToken()

Description copied from interface: IHASendState

The current quorum token on the sender.

Specified by:

getQuorumToken in interface IHASendState

getReplicationFactor

public int getReplicationFactor()

Description copied from interface: IHASendState

The current replication factor on the sender.

Specified by:

getReplicationFactor in interface IHASendState

getMarker

public byte[] getMarker()

Description copied from interface: IHASendState

A byte[] marker that must prefix the message payload, needed to skip stale data from failed read tasks.

Specified by:

getMarker in interface IHASendState

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

decode

public static IHASendState decode(byte[] a)
                           throws IOException

Decode the value returned by getMarker(). This has the magic followed by writeExternal2(DataOutput). It does not have the object serialization metadata.

Parameters:

a - The encoded marker.

Returns:

The decoded marker -or- null iff the argument is null.

Throws:

IOException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException