| 程序包 | 说明 |
|---|---|
| org.zodiac.rocketmq.client | |
| org.zodiac.rocketmq.client.config | |
| org.zodiac.rocketmq.client.util |
| 限定符和类型 | 字段和说明 |
|---|---|
private RocketMQInfo |
SwimlaneFilterMessageHook.rocketMQInfo |
| 构造器和说明 |
|---|
SwimlaneFilterMessageHook(RocketMQInfo rocketMQInfo,
AppContext appContext) |
| 限定符和类型 | 字段和说明 |
|---|---|
private Map<String,RocketMQInfo> |
RocketMQClientInfo.config |
| 限定符和类型 | 方法和说明 |
|---|---|
Map<String,RocketMQInfo> |
RocketMQClientInfo.getConfig() |
| 限定符和类型 | 字段和说明 |
|---|---|
private static Map<RocketMQInfo,org.apache.rocketmq.client.impl.factory.MQClientInstance> |
RocketMQClientUtil.adminClients |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
RocketMQClientUtil.addAdminClient(RocketMQInfo rocketMQInfo,
org.apache.rocketmq.client.impl.factory.MQClientInstance adminClient)
增加MQAdmin。
|
static org.apache.rocketmq.client.impl.factory.MQClientInstance |
RocketMQClientUtil.getAdminClient(RocketMQInfo rocketMQInfo)
获取MQAdmin。
|
static boolean |
RocketMQClientUtil.hasNameServer(RocketMQInfo rocketMQInfo)
是否配置了name server。
|
Copyright © 2025 Zodiac. All rights reserved.