com.tencent.tcaplus.message

Class MessageHandler

java.lang.Object

com.tencent.tcaplus.message.MessageHandler

All Implemented Interfaces:

Closeable, AutoCloseable

public class MessageHandler
extends Object
implements Closeable

Constructor Summary

Constructors

Constructor and Description
MessageHandler(ProtocolSupport protocolSupport, int handleThreadPoolSize, RequestMetrics requestMetrics)

Method Summary

Modifier and Type	Method and Description
void	close()
CostMetric	getCallbackMetric()
AtomicLong	getPollFail()
AtomicLong	getPollOk()
AtomicLong	getPostFail()
AtomicLong	getPostMultiFail()
AtomicLong	getPostMultiOk()
AtomicLong	getPostOk()
CostMetric	getRequestProcessMetric()
CostMetric	getRequestQueueMetric()
String	getThreadPoolInformation()
void	handleMessage(Message message)
void	onMessage(Message message)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageHandler

public MessageHandler(ProtocolSupport protocolSupport,
                      int handleThreadPoolSize,
                      RequestMetrics requestMetrics)

Method Detail

getThreadPoolInformation

public String getThreadPoolInformation()

getPollOk

public AtomicLong getPollOk()

getPollFail

public AtomicLong getPollFail()

getPostOk

public AtomicLong getPostOk()

getPostFail

public AtomicLong getPostFail()

getPostMultiOk

public AtomicLong getPostMultiOk()

getPostMultiFail

public AtomicLong getPostMultiFail()

getCallbackMetric

public CostMetric getCallbackMetric()

getRequestProcessMetric

public CostMetric getRequestProcessMetric()

getRequestQueueMetric

public CostMetric getRequestQueueMetric()

onMessage

public void onMessage(Message message)

handleMessage

public void handleMessage(Message message)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable