org.zodiac.rocketmq.client.consumer

类 SwimlaneConsumeMessageHook

java.lang.Object

org.zodiac.rocketmq.client.BaseRocketMQInfoAware

org.zodiac.rocketmq.client.consumer.SwimlaneConsumeMessageHook

所有已实现的接口:

org.apache.rocketmq.client.hook.ConsumeMessageHook, RocketMQInfoAware

public class SwimlaneConsumeMessageHook
extends BaseRocketMQInfoAware
implements org.apache.rocketmq.client.hook.ConsumeMessageHook

字段概要

从类继承的字段 org.zodiac.rocketmq.client.BaseRocketMQInfoAware

logger

构造器概要

构造器

构造器和说明
SwimlaneConsumeMessageHook()

方法概要

限定符和类型	方法和说明
void	consumeMessageAfter(org.apache.rocketmq.client.hook.ConsumeMessageContext context)
void	consumeMessageBefore(org.apache.rocketmq.client.hook.ConsumeMessageContext context)
String	hookName()
private void	logSwimLane(org.apache.rocketmq.common.message.Message msg, boolean before)

从类继承的方法 org.zodiac.rocketmq.client.BaseRocketMQInfoAware

getRocketMQConfigInfo, setRocketMQConfigInfo

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

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

构造器详细资料

SwimlaneConsumeMessageHook

public SwimlaneConsumeMessageHook()

方法详细资料

hookName

public String hookName()

指定者:

hookName 在接口中 org.apache.rocketmq.client.hook.ConsumeMessageHook

consumeMessageBefore

public void consumeMessageBefore(org.apache.rocketmq.client.hook.ConsumeMessageContext context)

指定者:

consumeMessageBefore 在接口中 org.apache.rocketmq.client.hook.ConsumeMessageHook

consumeMessageAfter

public void consumeMessageAfter(org.apache.rocketmq.client.hook.ConsumeMessageContext context)

指定者:

consumeMessageAfter 在接口中 org.apache.rocketmq.client.hook.ConsumeMessageHook

logSwimLane

private void logSwimLane(org.apache.rocketmq.common.message.Message msg,
                         boolean before)