org.zodiac.rocketmq.client

类 SwimlaneFilterMessageHook

java.lang.Object

org.zodiac.rocketmq.client.BaseRocketMQInfoAware

org.zodiac.rocketmq.client.SwimlaneFilterMessageHook

所有已实现的接口:

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

public class SwimlaneFilterMessageHook
extends BaseRocketMQInfoAware
implements org.apache.rocketmq.client.hook.FilterMessageHook

字段概要

字段

限定符和类型	字段和说明
private AppContext	appContext
private String	group
protected org.slf4j.Logger	logger
private RocketMQInfo	rocketMQInfo

构造器概要

构造器

构造器和说明
SwimlaneFilterMessageHook(RocketMQInfo rocketMQInfo, AppContext appContext)

方法概要

限定符和类型	方法和说明
void	filterMessage(org.apache.rocketmq.client.hook.FilterMessageContext context)
String	hookName()
private void	logSwimLane(org.apache.rocketmq.common.message.Message msg)
private boolean	matchByCondition(org.apache.rocketmq.common.message.Message message, CustomizedConsumeCondition condition)
private boolean	noMatchedSwimlaneEnvironmentConfigured(org.apache.rocketmq.common.message.Message message, String swimlaneFromMessage)

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

getRocketMQConfigInfo, setRocketMQConfigInfo

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

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

字段详细资料

logger

protected org.slf4j.Logger logger

rocketMQInfo

private RocketMQInfo rocketMQInfo

group

private String group

appContext

private AppContext appContext

构造器详细资料

SwimlaneFilterMessageHook

public SwimlaneFilterMessageHook(RocketMQInfo rocketMQInfo,
                                 AppContext appContext)

方法详细资料

hookName

public String hookName()

指定者:

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

filterMessage

public void filterMessage(org.apache.rocketmq.client.hook.FilterMessageContext context)

指定者:

filterMessage 在接口中 org.apache.rocketmq.client.hook.FilterMessageHook

matchByCondition

private boolean matchByCondition(org.apache.rocketmq.common.message.Message message,
                                 CustomizedConsumeCondition condition)

noMatchedSwimlaneEnvironmentConfigured

private boolean noMatchedSwimlaneEnvironmentConfigured(org.apache.rocketmq.common.message.Message message,
                                                       String swimlaneFromMessage)

logSwimLane

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