com.antchain.unionsdk.network

类 MessageProcessor

java.lang.Object

com.antchain.unionsdk.network.MessageProcessor

所有已实现的接口:

IProcessor

直接已知子类:

BtnMessageProcessor

public abstract class MessageProcessor
extends Object
implements IProcessor

字段概要

字段

限定符和类型	字段和说明
protected ConnectionPoolManager	connectionPoolManager
protected com.google.common.util.concurrent.ListeningExecutorService	msgProcessorExecutorService
protected AtomicLong	priorityCount
protected PriorityThreadPoolExecutor	priorityThreadPoolExecutor

构造器概要

构造器

构造器和说明
MessageProcessor(NetworkOption networkOption)

方法概要

限定符和类型	方法和说明
MessageContext	getAndDeleteContext(String sequence, String endpoint)
Map<String,IEventCallBack>	getEventMsgCallbacks()
Map<String,MessageContext>	getMessageContexts()
long	getReceiveTaskCount()
protected abstract void	onResponse(MessageContext context, ChainErrorCode sdkTimedOut)
Object	processMessage(Object data, String endpoint) process message
abstract boolean	processMsg(Object msg, String endpoint)
abstract boolean	processMsgWithPriorityThreadPool(byte[] msg, String endpoint)
boolean	processTimeoutMsg(String contextKey, Response response, String endpoint)
boolean	pushTimeoutMessage(String contextKey, Response response, String endpoint)
boolean	registerEvents(String type, IEventCallBack callback)
boolean	saveContext(String sequence, MessageContext context, String endpoint)
void	setConnectionPoolManager(ConnectionPoolManager connectionPoolManager)
void	setReceiveTaskCount(long receiveTaskCount)
boolean	shutDown()
boolean	start()
boolean	unRegisterEvents(String type)

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

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

字段详细资料

msgProcessorExecutorService

protected com.google.common.util.concurrent.ListeningExecutorService msgProcessorExecutorService

connectionPoolManager

protected ConnectionPoolManager connectionPoolManager

priorityThreadPoolExecutor

protected PriorityThreadPoolExecutor priorityThreadPoolExecutor

priorityCount

protected AtomicLong priorityCount

构造器详细资料

MessageProcessor

public MessageProcessor(NetworkOption networkOption)

方法详细资料

getMessageContexts

public Map<String,MessageContext> getMessageContexts()

getEventMsgCallbacks

public Map<String,IEventCallBack> getEventMsgCallbacks()

start

public boolean start()

processMessage

public Object processMessage(Object data,
                             String endpoint)

从接口复制的说明: IProcessor

process message

指定者:

processMessage 在接口中 IProcessor

参数:

data - msg

返回:

Object

processMsg

public abstract boolean processMsg(Object msg,
                                   String endpoint)

processMsgWithPriorityThreadPool

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

saveContext

public boolean saveContext(String sequence,
                           MessageContext context,
                           String endpoint)

getAndDeleteContext

public MessageContext getAndDeleteContext(String sequence,
                                          String endpoint)

registerEvents

public boolean registerEvents(String type,
                              IEventCallBack callback)

unRegisterEvents

public boolean unRegisterEvents(String type)

shutDown

public boolean shutDown()

pushTimeoutMessage

public boolean pushTimeoutMessage(String contextKey,
                                  Response response,
                                  String endpoint)

processTimeoutMsg

public boolean processTimeoutMsg(String contextKey,
                                 Response response,
                                 String endpoint)

onResponse

protected abstract void onResponse(MessageContext context,
                                   ChainErrorCode sdkTimedOut)

setConnectionPoolManager

public void setConnectionPoolManager(ConnectionPoolManager connectionPoolManager)

getReceiveTaskCount

public long getReceiveTaskCount()

setReceiveTaskCount

public void setReceiveTaskCount(long receiveTaskCount)