public class SwimlaneConsumeMessageHook extends BaseRocketMQInfoAware implements org.apache.rocketmq.client.hook.ConsumeMessageHook
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) |
getRocketMQConfigInfo, setRocketMQConfigInfopublic String hookName()
hookName 在接口中 org.apache.rocketmq.client.hook.ConsumeMessageHookpublic void consumeMessageBefore(org.apache.rocketmq.client.hook.ConsumeMessageContext context)
consumeMessageBefore 在接口中 org.apache.rocketmq.client.hook.ConsumeMessageHookpublic void consumeMessageAfter(org.apache.rocketmq.client.hook.ConsumeMessageContext context)
consumeMessageAfter 在接口中 org.apache.rocketmq.client.hook.ConsumeMessageHookprivate void logSwimLane(org.apache.rocketmq.common.message.Message msg,
boolean before)
Copyright © 2025 Zodiac. All rights reserved.