com.bigdata.ha.msg

Class HAMessageWrapper

java.lang.Object

com.bigdata.ha.msg.HAWriteMessageBase

com.bigdata.ha.msg.HAMessageWrapper

All Implemented Interfaces:

IHAMessage, IHAMessageWrapper, IHAWriteMessageBase, Externalizable, Serializable

public class HAMessageWrapper
extends HAWriteMessageBase
implements IHAMessageWrapper

Glue class wraps the IHAWriteMessage and the IHALogRequest message and exposes the requires IHAMessage interface to the HAReceiveService. This class is never persisted. It just let's us handshake with the HAReceiveService and get back out the original IHAWriteMessage as well as the optional IHALogRequest message.

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HAMessageWrapper(IHASyncRequest req, IHASendState snd, IHAWriteMessageBase msg)

Method Summary

Methods

Modifier and Type	Method and Description
IHASendState	getHASendState() Return information about the state of the sending service.
IHASyncRequest	getHASyncRequest() Return the optional IHASyncRequest.
IHAWriteMessageBase	getHAWriteMessage() Return the message that describes the payload that will be replicated along the pipeline.
byte[]	getMarker() Return the IHASendState.getMarker() iff there is an associated IHASendState and otherwise null.

Methods inherited from class com.bigdata.ha.msg.HAWriteMessageBase

equals, getChk, getSize, hashCode, readExternal, toString, writeExternal

Methods inherited from class java.lang.Object

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

Constructor Detail

HAMessageWrapper

public HAMessageWrapper(IHASyncRequest req,
                IHASendState snd,
                IHAWriteMessageBase msg)

Method Detail

getHASyncRequest

public IHASyncRequest getHASyncRequest()

Description copied from interface: IHAMessageWrapper

Return the optional IHASyncRequest. When available, this provides information about the service request that resulted in the transmission of the payload along the pipeline.

Specified by:

getHASyncRequest in interface IHAMessageWrapper

getHASendState

public IHASendState getHASendState()

Description copied from interface: IHAMessageWrapper

Return information about the state of the sending service.

Specified by:

getHASendState in interface IHAMessageWrapper

getHAWriteMessage

public IHAWriteMessageBase getHAWriteMessage()

Description copied from interface: IHAMessageWrapper

Return the message that describes the payload that will be replicated along the pipeline.

Specified by:

getHAWriteMessage in interface IHAMessageWrapper

getMarker

public byte[] getMarker()

Return the IHASendState.getMarker() iff there is an associated IHASendState and otherwise null.