org.zodiac.rocketmq.client.util

类 RocketMQClientUtil

java.lang.Object

org.zodiac.rocketmq.client.util.RocketMQClientUtil

public abstract class RocketMQClientUtil
extends Object

字段概要

字段

限定符和类型	字段和说明
private static Map<RocketMQInfo,org.apache.rocketmq.client.impl.factory.MQClientInstance>	adminClients
private static AtomicReference<org.springframework.context.ApplicationContext>	applicationContextRef
private static AtomicReference<RocketMQClientInfo>	configInfoRef

构造器概要

构造器

限定符	构造器和说明
private	RocketMQClientUtil()

方法概要

限定符和类型	方法和说明
static void	addAdminClient(RocketMQInfo rocketMQInfo, org.apache.rocketmq.client.impl.factory.MQClientInstance adminClient) 增加MQAdmin。
static org.apache.rocketmq.client.impl.factory.MQClientInstance	getAdminClient(RocketMQInfo rocketMQInfo) 获取MQAdmin。
static org.springframework.context.ApplicationContext	getApplicationContext()
static List<CustomizedConsumeWhiteList>	getCustomizedConsumeWhiteLists() 获取互斥策略。
static Optional<String>	getSwimLaneFromMessage(org.apache.rocketmq.common.message.Message msg) Get swim-lane from consumer message.
static boolean	hasNameServer(RocketMQInfo rocketMQInfo) 是否配置了name server。
static void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
static void	setConfigInfo(RocketMQClientInfo configInfo)
static boolean	swimlaneEnabled() 泳道环境是否开启。

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

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

字段详细资料

configInfoRef

private static volatile AtomicReference<RocketMQClientInfo> configInfoRef

applicationContextRef

private static volatile AtomicReference<org.springframework.context.ApplicationContext> applicationContextRef

adminClients

private static volatile Map<RocketMQInfo,org.apache.rocketmq.client.impl.factory.MQClientInstance> adminClients

构造器详细资料

RocketMQClientUtil

private RocketMQClientUtil()

方法详细资料

setConfigInfo

public static void setConfigInfo(RocketMQClientInfo configInfo)

setApplicationContext

public static void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

getApplicationContext

public static org.springframework.context.ApplicationContext getApplicationContext()

addAdminClient

public static void addAdminClient(RocketMQInfo rocketMQInfo,
                                  org.apache.rocketmq.client.impl.factory.MQClientInstance adminClient)

增加MQAdmin。

参数:

rocketMQInfo - RocketMQ配置

adminClient - MQClientInstance

getAdminClient

public static org.apache.rocketmq.client.impl.factory.MQClientInstance getAdminClient(RocketMQInfo rocketMQInfo)

获取MQAdmin。

参数:

rocketMQInfo - RocketMQ配置

返回:

MQClientInstance

hasNameServer

public static boolean hasNameServer(RocketMQInfo rocketMQInfo)

是否配置了name server。

参数:

rocketMQInfo - RocketMQ配置

返回:

是否配置

swimlaneEnabled

public static boolean swimlaneEnabled()

泳道环境是否开启。

返回:

是否开启

getCustomizedConsumeWhiteLists

public static List<CustomizedConsumeWhiteList> getCustomizedConsumeWhiteLists()

获取互斥策略。

返回:

自定义的消费白名单

getSwimLaneFromMessage

public static Optional<String> getSwimLaneFromMessage(org.apache.rocketmq.common.message.Message msg)

Get swim-lane from consumer message.

参数:

msg - 消费记录

返回:

消费记录