com.bigdata.ha.msg

Interface IHASendState

All Superinterfaces:

Serializable

All Known Implementing Classes:

HASendState

public interface IHASendState
extends Serializable

Interface for the state of the sender of an IHAMessage.

Author:

Bryan Thompson

Method Summary

Methods

Modifier and Type	Method and Description
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.

Method Detail

getMessageId

long getMessageId()

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.

getOriginalSenderId

UUID getOriginalSenderId()

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

getSenderId

UUID getSenderId()

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

getQuorumToken

long getQuorumToken()

The current quorum token on the sender.

getReplicationFactor

int getReplicationFactor()

The current replication factor on the sender.

getMarker

byte[] getMarker()

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