com.antchain.unionsdk.btn.api.network

类 BtnMessageProcessor

java.lang.Object

com.antchain.unionsdk.network.MessageProcessor

com.antchain.unionsdk.btn.api.network.BtnMessageProcessor

所有已实现的接口:

IProcessor

public class BtnMessageProcessor
extends MessageProcessor

字段概要

从类继承的字段 com.antchain.unionsdk.network.MessageProcessor

connectionPoolManager, msgProcessorExecutorService, priorityCount, priorityThreadPoolExecutor

构造器概要

构造器

构造器和说明
BtnMessageProcessor(NetworkOption networkOption, TimerTaskManager timerTaskManager)

方法概要

限定符和类型	方法和说明
protected void	onResponse(MessageContext context, ChainErrorCode sdkTimedOut)
boolean	processMsg(Object msg, String endpoint)
boolean	processMsgWithPriorityThreadPool(byte[] msg, String endpoint)

从类继承的方法 com.antchain.unionsdk.network.MessageProcessor

getAndDeleteContext, getEventMsgCallbacks, getMessageContexts, getReceiveTaskCount, processMessage, processTimeoutMsg, pushTimeoutMessage, registerEvents, saveContext, setConnectionPoolManager, setReceiveTaskCount, shutDown, start, unRegisterEvents

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

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

构造器详细资料

BtnMessageProcessor

public BtnMessageProcessor(NetworkOption networkOption,
                           TimerTaskManager timerTaskManager)

方法详细资料

processMsgWithPriorityThreadPool

public boolean processMsgWithPriorityThreadPool(byte[] msg,
                                                String endpoint)

指定者:

processMsgWithPriorityThreadPool 在类中 MessageProcessor

processMsg

public boolean processMsg(Object msg,
                          String endpoint)

指定者:

processMsg 在类中 MessageProcessor

onResponse

protected void onResponse(MessageContext context,
                          ChainErrorCode sdkTimedOut)

指定者:

onResponse 在类中 MessageProcessor