com.aliyun.openservices.ons.api.impl.rocketmq

Class AbstractRPCHook

java.lang.Object

com.aliyun.openservices.ons.api.impl.rocketmq.AbstractRPCHook

All Implemented Interfaces:

com.alibaba.rocketmq.remoting.RPCHook

Direct Known Subclasses:

ClientRPCHook

public abstract class AbstractRPCHook
extends Object
implements com.alibaba.rocketmq.remoting.RPCHook

Author:

MQDevelopers

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentHashMap<Class<? extends com.alibaba.rocketmq.remoting.CommandCustomHeader>,Field[]>	fieldCache

Constructor Summary

Constructors

Constructor and Description
AbstractRPCHook()

Method Summary

Methods

Modifier and Type	Method and Description
protected SortedMap<String,String>	parseRequestContent(com.alibaba.rocketmq.remoting.protocol.RemotingCommand request, String ak, String securityToken, String onsChannel)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.alibaba.rocketmq.remoting.RPCHook

doAfterResponse, doBeforeRequest

Field Detail

fieldCache

protected ConcurrentHashMap<Class<? extends com.alibaba.rocketmq.remoting.CommandCustomHeader>,Field[]> fieldCache

Constructor Detail

AbstractRPCHook

public AbstractRPCHook()

Method Detail

parseRequestContent

protected SortedMap<String,String> parseRequestContent(com.alibaba.rocketmq.remoting.protocol.RemotingCommand request,
                                           String ak,
                                           String securityToken,
                                           String onsChannel)