com.tencent.tcaplus.message.impl

Class ProtocolSupportImpl

java.lang.Object

com.tencent.tcaplus.message.impl.ProtocolSupportImpl

All Implemented Interfaces:

ProtocolSupport

public class ProtocolSupportImpl
extends Object
implements ProtocolSupport

Constructor Summary

Constructors

Constructor and Description
ProtocolSupportImpl(int appId, int zoneId, String signature, String apiVersion)

Method Summary

Modifier and Type	Method and Description
int	getAppId()
MessageBuffer	getAuthorizedReq() 获得一个鉴权请求消息二进制包
MessageBuffer	getDirHeartbeatReq(String qosReport) 获得一个心跳通知请求消息二进制包
MessageBuffer	getDirServerListReq()
MessageBuffer	getMetadataReq(String tableName)
MessageBuffer	getProxyHeartBeatReq(int appId, int zoneId, String dirAlarmCodes) 获得一个心跳通知请求消息二进制包
MessageBuffer	getProxyStopRsp(MessageBuffer req) 获得Proxy停止响应消息二进制包
MessageBufferPool	getRecvPool()
MessageBufferPool	getSendPool()
String	getSignature()
MessageBuffer	getSignUpAppReq()
MessageBuffer	getTableAndAccessReq() 获得Proxy路由拉取请求消息二进制包
int	getZoneId()
MessageBuffer	packRequest(Request req)
void	setAppId(int appId)
void	setSignature(String signature)
void	setZoneId(int zoneId)
ResGetDirServerList	unpackGetDirServerListRes(MessageBuffer msg)
ResGetTablesAndAccess	unpackGetTablesAndAccessRes(MessageBuffer msg)
Response	unpackResponse(MessageBuffer msg)
ResSignUpApp	unpackSignUpRes(MessageBuffer msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtocolSupportImpl

public ProtocolSupportImpl(int appId,
                           int zoneId,
                           String signature,
                           String apiVersion)

Method Detail

getAuthorizedReq

public MessageBuffer getAuthorizedReq()
                               throws TdrException

Description copied from interface: ProtocolSupport

获得一个鉴权请求消息二进制包

Specified by:

getAuthorizedReq in interface ProtocolSupport

Returns:

鉴权请求消息二进制包

Throws:

TdrException

getProxyStopRsp

public MessageBuffer getProxyStopRsp(MessageBuffer req)
                              throws TdrException

Description copied from interface: ProtocolSupport

获得Proxy停止响应消息二进制包

Specified by:

getProxyStopRsp in interface ProtocolSupport

Returns:

Proxy停止响应消息二进制包

Throws:

TdrException

getProxyHeartBeatReq

public MessageBuffer getProxyHeartBeatReq(int appId,
                                          int zoneId,
                                          String dirAlarmCodes)
                                   throws TdrException

Description copied from interface: ProtocolSupport

获得一个心跳通知请求消息二进制包

Specified by:

getProxyHeartBeatReq in interface ProtocolSupport

Returns:

心跳通知请求消息二进制包

Throws:

TdrException

getDirHeartbeatReq

public MessageBuffer getDirHeartbeatReq(String qosReport)
                                 throws TdrException

Description copied from interface: ProtocolSupport

获得一个心跳通知请求消息二进制包

Specified by:

getDirHeartbeatReq in interface ProtocolSupport

Returns:

心跳通知请求消息二进制包

Throws:

TdrException

getTableAndAccessReq

public MessageBuffer getTableAndAccessReq()
                                   throws TdrException

Description copied from interface: ProtocolSupport

获得Proxy路由拉取请求消息二进制包

Specified by:

getTableAndAccessReq in interface ProtocolSupport

Returns:

路由拉取请求消息二进制包

Throws:

TdrException

getSignUpAppReq

public MessageBuffer getSignUpAppReq()
                              throws TdrException

Specified by:

getSignUpAppReq in interface ProtocolSupport

Throws:

TdrException

getMetadataReq

public MessageBuffer getMetadataReq(String tableName)
                             throws TdrException

Specified by:

getMetadataReq in interface ProtocolSupport

Throws:

TdrException

getDirServerListReq

public MessageBuffer getDirServerListReq()
                                  throws TdrException

Specified by:

getDirServerListReq in interface ProtocolSupport

Throws:

TdrException

packRequest

public MessageBuffer packRequest(Request req)
                          throws TdrException

Specified by:

packRequest in interface ProtocolSupport

Throws:

TdrException

unpackResponse

public Response unpackResponse(MessageBuffer msg)
                        throws TdrException

Specified by:

unpackResponse in interface ProtocolSupport

Throws:

TdrException

unpackSignUpRes

public ResSignUpApp unpackSignUpRes(MessageBuffer msg)
                             throws TdrException

Specified by:

unpackSignUpRes in interface ProtocolSupport

Throws:

TdrException

unpackGetTablesAndAccessRes

public ResGetTablesAndAccess unpackGetTablesAndAccessRes(MessageBuffer msg)
                                                  throws TdrException

Specified by:

unpackGetTablesAndAccessRes in interface ProtocolSupport

Throws:

TdrException

unpackGetDirServerListRes

public ResGetDirServerList unpackGetDirServerListRes(MessageBuffer msg)
                                              throws TdrException

Specified by:

unpackGetDirServerListRes in interface ProtocolSupport

Throws:

TdrException

getSignature

public String getSignature()

setSignature

public void setSignature(String signature)

getAppId

public int getAppId()

setAppId

public void setAppId(int appId)

getZoneId

public int getZoneId()

setZoneId

public void setZoneId(int zoneId)

getSendPool

public MessageBufferPool getSendPool()

Specified by:

getSendPool in interface ProtocolSupport

getRecvPool

public MessageBufferPool getRecvPool()

Specified by:

getRecvPool in interface ProtocolSupport