com.tencent.tcaplus.message.impl

Class MessageImpl

java.lang.Object

com.tencent.tcaplus.message.impl.MessageImpl

All Implemented Interfaces:

Message

public class MessageImpl
extends Object
implements Message

Field Summary

Fields

Modifier and Type	Field and Description
Object	lock

Constructor Summary

Constructors

Constructor and Description
MessageImpl(ProtocolSupport protocolSupport)

Method Summary

Modifier and Type	Method and Description
Response	buildResponse()
Message	clone()
void	close()
int	getClientResult()
int	getCmd()
Connector	getConnector()
long	getCreatTime()
String	getErrMsg()
Future	getFuture()
short	getMagic()
MessageFuture	getMessageFuture()
int	getMultiResponseFlag()
int	getNextExpectedResponseSequence()
Object	getPollLock()
long	getReceiveTime()
MessageBuffer	getRecvBuffer()
int	getRecvCmd()
short	getRecvMagic()
int	getRecvSize()
int	getResultLimit()
long	getRouteHash()
Response	getRsp()
MessageBuffer	getSendBuffer()
int	getSendSize()
long	getSendTime()
int	getSeq()
boolean	hasMore(int recordCount)
boolean	isGetRawMeta()
boolean	isTicket()
void	releaseRecvBuf()
void	releaseSendBuf()
void	setClientError(int errno, String errMsg)
void	setCmd(int cmd)
void	setConnector(Connector connector)
void	setFuture(Future future)
void	setGetRawMeta(boolean isGetRawMeta)
void	setMagic(short magic)
void	setMessageFuture(MessageFuture future)
void	setMultiResponseFlag(int multi)
void	setNextExpectedResponseSequence(int nextExpectedResponseSequence)
void	setReceiveTime(long receiveTime)
void	setRecvBuffer(MessageBuffer msgBuf)
void	setRecvCmd(int cmd)
void	setRecvMagic(short recvMagic)
void	setResultLimit(int resultLimit)
void	setRouteHash(long routeHash)
void	setRsp(Response rsp)
void	setSendBuffer(MessageBuffer msgBuf)
void	setSendTime(long sendTime)
void	setSeq(int seq)
void	setTicket(boolean ticket)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

lock

public Object lock

Constructor Detail

MessageImpl

public MessageImpl(ProtocolSupport protocolSupport)

Method Detail

setSendBuffer

public void setSendBuffer(MessageBuffer msgBuf)

Specified by:

setSendBuffer in interface Message

getSendBuffer

public MessageBuffer getSendBuffer()

Specified by:

getSendBuffer in interface Message

setSendTime

public void setSendTime(long sendTime)

Specified by:

setSendTime in interface Message

getSendTime

public long getSendTime()

Specified by:

getSendTime in interface Message

setClientError

public void setClientError(int errno,
                           String errMsg)

Specified by:

setClientError in interface Message

setRecvBuffer

public void setRecvBuffer(MessageBuffer msgBuf)

Specified by:

setRecvBuffer in interface Message

setReceiveTime

public void setReceiveTime(long receiveTime)

Specified by:

setReceiveTime in interface Message

getReceiveTime

public long getReceiveTime()

Specified by:

getReceiveTime in interface Message

getRecvBuffer

public MessageBuffer getRecvBuffer()

Specified by:

getRecvBuffer in interface Message

getRouteHash

public long getRouteHash()

Specified by:

getRouteHash in interface Message

setMessageFuture

public void setMessageFuture(MessageFuture future)

Specified by:

setMessageFuture in interface Message

setMagic

public void setMagic(short magic)

Specified by:

setMagic in interface Message

getMagic

public short getMagic()

Specified by:

getMagic in interface Message

getRecvMagic

public short getRecvMagic()

Specified by:

getRecvMagic in interface Message

setRecvMagic

public void setRecvMagic(short recvMagic)

Specified by:

setRecvMagic in interface Message

setCmd

public void setCmd(int cmd)

Specified by:

setCmd in interface Message

getCmd

public int getCmd()

Specified by:

getCmd in interface Message

setConnector

public void setConnector(Connector connector)

Specified by:

setConnector in interface Message

getConnector

public Connector getConnector()

Specified by:

getConnector in interface Message

getMessageFuture

public MessageFuture getMessageFuture()

Specified by:

getMessageFuture in interface Message

setRouteHash

public void setRouteHash(long routeHash)

Specified by:

setRouteHash in interface Message

getClientResult

public int getClientResult()

Specified by:

getClientResult in interface Message

setFuture

public void setFuture(Future future)

Specified by:

setFuture in interface Message

getFuture

public Future getFuture()

Specified by:

getFuture in interface Message

setSeq

public void setSeq(int seq)

Specified by:

setSeq in interface Message

getSeq

public int getSeq()

Specified by:

getSeq in interface Message

setResultLimit

public void setResultLimit(int resultLimit)

Specified by:

setResultLimit in interface Message

getResultLimit

public int getResultLimit()

Specified by:

getResultLimit in interface Message

hasMore

public boolean hasMore(int recordCount)

Specified by:

hasMore in interface Message

getCreatTime

public long getCreatTime()

Specified by:

getCreatTime in interface Message

getRecvCmd

public int getRecvCmd()

Specified by:

getRecvCmd in interface Message

setRecvCmd

public void setRecvCmd(int cmd)

Specified by:

setRecvCmd in interface Message

getPollLock

public Object getPollLock()

Specified by:

getPollLock in interface Message

setTicket

public void setTicket(boolean ticket)

Specified by:

setTicket in interface Message

isTicket

public boolean isTicket()

Specified by:

isTicket in interface Message

close

public void close()

Specified by:

close in interface Message

setMultiResponseFlag

public void setMultiResponseFlag(int multi)

Specified by:

setMultiResponseFlag in interface Message

getMultiResponseFlag

public int getMultiResponseFlag()

Specified by:

getMultiResponseFlag in interface Message

getSendSize

public int getSendSize()

Specified by:

getSendSize in interface Message

getRecvSize

public int getRecvSize()

Specified by:

getRecvSize in interface Message

getErrMsg

public String getErrMsg()

Specified by:

getErrMsg in interface Message

buildResponse

public Response buildResponse()

Specified by:

buildResponse in interface Message

releaseSendBuf

public void releaseSendBuf()

Specified by:

releaseSendBuf in interface Message

releaseRecvBuf

public void releaseRecvBuf()

Specified by:

releaseRecvBuf in interface Message

setRsp

public void setRsp(Response rsp)

Specified by:

setRsp in interface Message

getRsp

public Response getRsp()

Specified by:

getRsp in interface Message

isGetRawMeta

public boolean isGetRawMeta()

Specified by:

isGetRawMeta in interface Message

setGetRawMeta

public void setGetRawMeta(boolean isGetRawMeta)

Specified by:

setGetRawMeta in interface Message

getNextExpectedResponseSequence

public int getNextExpectedResponseSequence()

Specified by:

getNextExpectedResponseSequence in interface Message

setNextExpectedResponseSequence

public void setNextExpectedResponseSequence(int nextExpectedResponseSequence)

Specified by:

setNextExpectedResponseSequence in interface Message

clone

public Message clone()

Specified by:

clone in interface Message

Overrides:

clone in class Object

toString

public String toString()

Overrides:

toString in class Object