com.alipay.mychain.sdk.network

类 MessageProcessor

java.lang.Object

com.alipay.mychain.sdk.network.MessageProcessor

所有已实现的接口:

IProcessor

public class MessageProcessor
extends Object
implements IProcessor

版本:

$Id: MessageProcessor, v0.1 2019年05月02日 下午8:37 xiuyi.lp Exp $

作者:

xiuyi.lp

构造器概要

构造器

构造器和说明
MessageProcessor(TimerTaskManager timerTaskManager, NetworkOption networkOption, ICodec codec, ILogger logger)
MessageProcessor(TimerTaskManager timerTaskManager, NetworkOption networkOption, ICodec codec, ILogger logger, ClientEnv clientEnv)

方法概要

限定符和类型	方法和说明
MessageContext	getContext(long sequence)
boolean	processMsg(Object msg, String endpoint)
boolean	processTimeoutMsg(long sequence, Response response)
boolean	pushMessage(Object msg, String endpoint) push message
boolean	pushTimeoutMessage(long sequence, Response response)
boolean	registerEventHandler(MessageType type, IEventCallback callback)
boolean	saveContext(MessageContext context)
void	setConnectionPoolManager(ConnectionPoolManager connectionPoolManager)
void	setHandshakeCallback(String endpoint, IHandshakeCallback callback)
boolean	start()
boolean	stop()
boolean	unRegisterEventHandler(MessageType type)

从类继承的方法 java.lang.Object

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

构造器详细资料

MessageProcessor

public MessageProcessor(TimerTaskManager timerTaskManager,
                        NetworkOption networkOption,
                        ICodec codec,
                        ILogger logger)

MessageProcessor

public MessageProcessor(TimerTaskManager timerTaskManager,
                        NetworkOption networkOption,
                        ICodec codec,
                        ILogger logger,
                        ClientEnv clientEnv)

方法详细资料

start

public boolean start()

stop

public boolean stop()

registerEventHandler

public boolean registerEventHandler(MessageType type,
                                    IEventCallback callback)

unRegisterEventHandler

public boolean unRegisterEventHandler(MessageType type)

saveContext

public boolean saveContext(MessageContext context)

getContext

public MessageContext getContext(long sequence)

pushMessage

public boolean pushMessage(Object msg,
                           String endpoint)

从接口复制的说明: IProcessor

push message

指定者:

pushMessage 在接口中 IProcessor

参数:

msg - msg

返回:

boolean

pushTimeoutMessage

public boolean pushTimeoutMessage(long sequence,
                                  Response response)

processMsg

public boolean processMsg(Object msg,
                          String endpoint)

processTimeoutMsg

public boolean processTimeoutMsg(long sequence,
                                 Response response)

setHandshakeCallback

public void setHandshakeCallback(String endpoint,
                                 IHandshakeCallback callback)

setConnectionPoolManager

public void setConnectionPoolManager(ConnectionPoolManager connectionPoolManager)