概述  软件包   类  使用  树  已过时  索引  帮助 
 上一个类   下一个类 框架    无框架    
摘要： 嵌套 | 字段 | 构造方法 | 方法 详细信息： 字段 | 构造方法 | 方法

com.alibaba.rocketmq.tools.admin
类 DefaultMQAdminExt

java.lang.Object
  继承者 com.alibaba.rocketmq.client.ClientConfig
      继承者 com.alibaba.rocketmq.tools.admin.DefaultMQAdminExt
所有已实现的接口：
MQAdmin, MQAdminExt
public class DefaultMQAdminExt
extends ClientConfig
implements MQAdminExt

所有运维接口都在这里实现

从以下版本开始：
2013-7-14
作者：
shijia.wxr

构造方法摘要
DefaultMQAdminExt()
           
DefaultMQAdminExt(RPCHook rpcHook)
           
DefaultMQAdminExt(String adminExtGroup)
           
 
方法摘要
 boolean cleanExpiredConsumerQueue(String cluster)
          触发清理失效的消费队列
 boolean cleanExpiredConsumerQueueByAddr(String addr)
          触发指定的broker清理失效的消费队列
 void cloneGroupOffset(String srcGroup, String destGroup, String topic, boolean isOffline)
          克隆某一个组的消费进度到新的组
 ConsumeMessageDirectlyResult consumeMessageDirectly(String consumerGroup, String clientId, String msgId)
          向指定Consumer发送某条消息
 void createAndUpdateKvConfig(String namespace, String key, String value)
          在 namespace 上添加或者更新 KV 配置
 void createAndUpdateSubscriptionGroupConfig(String addr, SubscriptionGroupConfig config)
          向指定Broker创建或者更新订阅组配置
 void createAndUpdateTopicConfig(String addr, TopicConfig config)
          向指定Broker创建或者更新Topic配置
 void createOrUpdateOrderConf(String key, String value, boolean isCluster)
          创建或更新顺序消息的分区配置
 void createTopic(String key, String newTopic, int queueNum)
           
 void createTopic(String key, String newTopic, int queueNum, int topicSysFlag)
           
 void deleteIpsByProjectGroup(String projectGroup)
          删除 project group 对应的所有 server ip
 void deleteKvConfig(String namespace, String key)
          删除 namespace 上的 KV 配置
 void deleteSubscriptionGroup(String addr, String groupName)
          删除 broker 上的 subscription group 信息
 void deleteTopicInBroker(Set<String> addrs, String topic)
          删除 broker 上的 topic 信息
 void deleteTopicInNameServer(Set<String> addrs, String topic)
          删除 broker 上的 topic 信息
 long earliestMsgStoreTime(MessageQueue mq)
           
 ClusterInfo examineBrokerClusterInfo()
          查看集群信息
 ConsumerConnection examineConsumerConnectionInfo(String consumerGroup)
          查看Consumer网络连接、订阅关系
 ConsumeStats examineConsumeStats(String consumerGroup)
          查询消费进度
 ConsumeStats examineConsumeStats(String consumerGroup, String topic)
           
 ProducerConnection examineProducerConnectionInfo(String producerGroup, String topic)
          查看Producer网络连接
 SubscriptionGroupConfig examineSubscriptionGroupConfig(String addr, String group)
          查询指定Broker的订阅组配置
 TopicConfig examineTopicConfig(String addr, String topic)
          查询指定Broker的Topic配置
 TopicRouteData examineTopicRouteInfo(String topic)
          查看Topic路由信息
 TopicStatsTable examineTopicStats(String topic)
          查询Topic Offset信息
 TopicList fetchAllTopicList()
          从Name Server获取所有Topic列表
 KVTable fetchBrokerRuntimeStats(String brokerAddr)
          获取Broker运行时数据
 String getAdminExtGroup()
           
 ConsumerRunningInfo getConsumerRunningInfo(String consumerGroup, String clientId, boolean jstack)
          查询Consumer内存数据结构
 Map<String,Map<MessageQueue,Long>> getConsumeStatus(String topic, String group, String clientAddr)
          通过客户端查看消费者的消费情况
 String getCreateTopicKey()
           
 String getIpsByProjectGroup(String projectGroup)
          通过 project 获取所有的 server ip 信息
 String getKVConfig(String namespace, String key)
          从Name Server获取一个配置项
 KVTable getKVListByNamespace(String namespace)
          获取指定Namespace下的所有kv
 List<String> getNameServerAddressList()
          获取Name Server地址列表
 String getProjectGroupByIp(String ip)
          通过 server ip 获取 project 信息
 long maxOffset(MessageQueue mq)
           
 List<MessageTrack> messageTrackDetail(MessageExt msg)
          查询消息被谁消费了
 long minOffset(MessageQueue mq)
           
 void putKVConfig(String namespace, String key, String value)
          向Name Server增加一个配置项
 Set<QueueTimeSpan> queryConsumeTimeSpan(String topic, String group)
          根据 topic 和 group 获取消息的时间跨度
 QueryResult queryMessage(String topic, String key, int maxNum, long begin, long end)
           
 GroupList queryTopicConsumeByWho(String topic)
          根据Topic查询被哪些订阅组消费
 Map<MessageQueue,Long> resetOffsetByTimestamp(String topic, String group, long timestamp, boolean isForce)
          按照时间回溯消费进度(客户端不需要重启)
 List<RollbackStats> resetOffsetByTimestampOld(String consumerGroup, String topic, long timestamp, boolean force)
          按照时间回溯消费进度(客户端需要重启)
 void resetOffsetNew(String consumerGroup, String topic, long timestamp)
          重置消费进度，无论Consumer是否在线，都可以执行。
 long searchOffset(MessageQueue mq, long timestamp)
           
 void setAdminExtGroup(String adminExtGroup)
           
 void setCreateTopicKey(String createTopicKey)
           
 void shutdown()
           
 void start()
           
 void updateBrokerConfig(String brokerAddr, Properties properties)
          更新Broker配置
 BrokerStatsData ViewBrokerStatsData(String brokerAddr, String statsName, String statsKey)
          服务器统计数据输出
 MessageExt viewMessage(String msgId)
           
 int wipeWritePermOfBroker(String namesrvAddr, String brokerName)
          清除某个Broker的写权限，针对所有Name Server
 
从类 com.alibaba.rocketmq.client.ClientConfig 继承的方法
buildMQClientId, changeInstanceNameToPID, cloneClientConfig, getClientCallbackExecutorThreads, getClientIP, getHeartbeatBrokerInterval, getInstanceName, getNamesrvAddr, getPersistConsumerOffsetInterval, getPollNameServerInteval, resetClientConfig, setClientCallbackExecutorThreads, setClientIP, setHeartbeatBrokerInterval, setInstanceName, setNamesrvAddr, setPersistConsumerOffsetInterval, setPollNameServerInteval, toString
 
从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

构造方法详细信息

DefaultMQAdminExt

public DefaultMQAdminExt()

DefaultMQAdminExt

public DefaultMQAdminExt(RPCHook rpcHook)

DefaultMQAdminExt

public DefaultMQAdminExt(String adminExtGroup)
方法详细信息

createTopic

public void createTopic(String key,
                        String newTopic,
                        int queueNum)
                 throws MQClientException
指定者：
接口 MQAdmin 中的 createTopic
抛出：
MQClientException

createTopic

public void createTopic(String key,
                        String newTopic,
                        int queueNum,
                        int topicSysFlag)
                 throws MQClientException
指定者：
接口 MQAdmin 中的 createTopic
抛出：
MQClientException

searchOffset

public long searchOffset(MessageQueue mq,
                         long timestamp)
                  throws MQClientException
指定者：
接口 MQAdmin 中的 searchOffset
抛出：
MQClientException

maxOffset

public long maxOffset(MessageQueue mq)
               throws MQClientException
指定者：
接口 MQAdmin 中的 maxOffset
抛出：
MQClientException

minOffset

public long minOffset(MessageQueue mq)
               throws MQClientException
指定者：
接口 MQAdmin 中的 minOffset
抛出：
MQClientException

earliestMsgStoreTime

public long earliestMsgStoreTime(MessageQueue mq)
                          throws MQClientException
指定者：
接口 MQAdmin 中的 earliestMsgStoreTime
抛出：
MQClientException

viewMessage

public MessageExt viewMessage(String msgId)
                       throws RemotingException,
                              MQBrokerException,
                              InterruptedException,
                              MQClientException
指定者：
接口 MQAdmin 中的 viewMessage
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

queryMessage

public QueryResult queryMessage(String topic,
                                String key,
                                int maxNum,
                                long begin,
                                long end)
                         throws MQClientException,
                                InterruptedException
指定者：
接口 MQAdmin 中的 queryMessage
抛出：
MQClientException
InterruptedException

start

public void start()
           throws MQClientException
指定者：
接口 MQAdminExt 中的 start
抛出：
MQClientException

shutdown

public void shutdown()
指定者：
接口 MQAdminExt 中的 shutdown

createAndUpdateTopicConfig

public void createAndUpdateTopicConfig(String addr,
                                       TopicConfig config)
                                throws RemotingException,
                                       MQBrokerException,
                                       InterruptedException,
                                       MQClientException
从接口 MQAdminExt 复制的描述
向指定Broker创建或者更新Topic配置

指定者：
接口 MQAdminExt 中的 createAndUpdateTopicConfig
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

createAndUpdateSubscriptionGroupConfig

public void createAndUpdateSubscriptionGroupConfig(String addr,
                                                   SubscriptionGroupConfig config)
                                            throws RemotingException,
                                                   MQBrokerException,
                                                   InterruptedException,
                                                   MQClientException
从接口 MQAdminExt 复制的描述
向指定Broker创建或者更新订阅组配置

指定者：
接口 MQAdminExt 中的 createAndUpdateSubscriptionGroupConfig
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

examineSubscriptionGroupConfig

public SubscriptionGroupConfig examineSubscriptionGroupConfig(String addr,
                                                              String group)
从接口 MQAdminExt 复制的描述
查询指定Broker的订阅组配置

指定者：
接口 MQAdminExt 中的 examineSubscriptionGroupConfig
返回：

examineTopicConfig

public TopicConfig examineTopicConfig(String addr,
                                      String topic)
从接口 MQAdminExt 复制的描述
查询指定Broker的Topic配置

指定者：
接口 MQAdminExt 中的 examineTopicConfig
返回：

examineTopicStats

public TopicStatsTable examineTopicStats(String topic)
                                  throws RemotingException,
                                         MQClientException,
                                         InterruptedException,
                                         MQBrokerException
从接口 MQAdminExt 复制的描述
查询Topic Offset信息

指定者：
接口 MQAdminExt 中的 examineTopicStats
返回：
抛出：
RemotingException
MQClientException
InterruptedException
MQBrokerException

examineConsumeStats

public ConsumeStats examineConsumeStats(String consumerGroup)
                                 throws RemotingException,
                                        MQClientException,
                                        InterruptedException,
                                        MQBrokerException
从接口 MQAdminExt 复制的描述
查询消费进度

指定者：
接口 MQAdminExt 中的 examineConsumeStats
返回：
抛出：
RemotingException
MQClientException
InterruptedException
MQBrokerException

examineConsumeStats

public ConsumeStats examineConsumeStats(String consumerGroup,
                                        String topic)
                                 throws RemotingException,
                                        MQClientException,
                                        InterruptedException,
                                        MQBrokerException
指定者：
接口 MQAdminExt 中的 examineConsumeStats
抛出：
RemotingException
MQClientException
InterruptedException
MQBrokerException

examineBrokerClusterInfo

public ClusterInfo examineBrokerClusterInfo()
                                     throws InterruptedException,
                                            RemotingConnectException,
                                            RemotingTimeoutException,
                                            RemotingSendRequestException,
                                            MQBrokerException
从接口 MQAdminExt 复制的描述
查看集群信息

指定者：
接口 MQAdminExt 中的 examineBrokerClusterInfo
返回：
抛出：
InterruptedException
RemotingConnectException
RemotingTimeoutException
RemotingSendRequestException
MQBrokerException

examineTopicRouteInfo

public TopicRouteData examineTopicRouteInfo(String topic)
                                     throws RemotingException,
                                            MQClientException,
                                            InterruptedException
从接口 MQAdminExt 复制的描述
查看Topic路由信息

指定者：
接口 MQAdminExt 中的 examineTopicRouteInfo
返回：
抛出：
RemotingException
MQClientException
InterruptedException

putKVConfig

public void putKVConfig(String namespace,
                        String key,
                        String value)
从接口 MQAdminExt 复制的描述
向Name Server增加一个配置项

指定者：
接口 MQAdminExt 中的 putKVConfig

getKVConfig

public String getKVConfig(String namespace,
                          String key)
                   throws RemotingException,
                          MQClientException,
                          InterruptedException
从接口 MQAdminExt 复制的描述
从Name Server获取一个配置项

指定者：
接口 MQAdminExt 中的 getKVConfig
返回：
抛出：
RemotingException
MQClientException
InterruptedException

examineConsumerConnectionInfo

public ConsumerConnection examineConsumerConnectionInfo(String consumerGroup)
                                                 throws InterruptedException,
                                                        MQBrokerException,
                                                        RemotingException,
                                                        MQClientException
从接口 MQAdminExt 复制的描述
查看Consumer网络连接、订阅关系

指定者：
接口 MQAdminExt 中的 examineConsumerConnectionInfo
返回：
抛出：
InterruptedException
MQBrokerException
RemotingTimeoutException
RemotingSendRequestException
RemotingConnectException
RemotingException
MQClientException

examineProducerConnectionInfo

public ProducerConnection examineProducerConnectionInfo(String producerGroup,
                                                        String topic)
                                                 throws RemotingException,
                                                        MQClientException,
                                                        InterruptedException,
                                                        MQBrokerException
从接口 MQAdminExt 复制的描述
查看Producer网络连接

指定者：
接口 MQAdminExt 中的 examineProducerConnectionInfo
返回：
抛出：
RemotingException
MQClientException
InterruptedException
MQBrokerException

wipeWritePermOfBroker

public int wipeWritePermOfBroker(String namesrvAddr,
                                 String brokerName)
                          throws RemotingCommandException,
                                 RemotingConnectException,
                                 RemotingSendRequestException,
                                 RemotingTimeoutException,
                                 InterruptedException,
                                 MQClientException
从接口 MQAdminExt 复制的描述
清除某个Broker的写权限，针对所有Name Server

指定者：
接口 MQAdminExt 中的 wipeWritePermOfBroker
返回：
返回清除了多少个topic
抛出：
RemotingCommandException
RemotingConnectException
RemotingSendRequestException
RemotingTimeoutException
InterruptedException
MQClientException

getAdminExtGroup

public String getAdminExtGroup()

setAdminExtGroup

public void setAdminExtGroup(String adminExtGroup)

getCreateTopicKey

public String getCreateTopicKey()

setCreateTopicKey

public void setCreateTopicKey(String createTopicKey)

getNameServerAddressList

public List<String> getNameServerAddressList()
从接口 MQAdminExt 复制的描述
获取Name Server地址列表

指定者：
接口 MQAdminExt 中的 getNameServerAddressList
返回：

fetchAllTopicList

public TopicList fetchAllTopicList()
                            throws RemotingException,
                                   MQClientException,
                                   InterruptedException
从接口 MQAdminExt 复制的描述
从Name Server获取所有Topic列表

指定者：
接口 MQAdminExt 中的 fetchAllTopicList
返回：
抛出：
RemotingException
MQClientException
InterruptedException

fetchBrokerRuntimeStats

public KVTable fetchBrokerRuntimeStats(String brokerAddr)
                                throws RemotingConnectException,
                                       RemotingSendRequestException,
                                       RemotingTimeoutException,
                                       InterruptedException,
                                       MQBrokerException
从接口 MQAdminExt 复制的描述
获取Broker运行时数据

指定者：
接口 MQAdminExt 中的 fetchBrokerRuntimeStats
返回：
抛出：
RemotingConnectException
RemotingSendRequestException
RemotingTimeoutException
InterruptedException
MQBrokerException

deleteTopicInBroker

public void deleteTopicInBroker(Set<String> addrs,
                                String topic)
                         throws RemotingException,
                                MQBrokerException,
                                InterruptedException,
                                MQClientException
从接口 MQAdminExt 复制的描述
删除 broker 上的 topic 信息

指定者：
接口 MQAdminExt 中的 deleteTopicInBroker
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

deleteTopicInNameServer

public void deleteTopicInNameServer(Set<String> addrs,
                                    String topic)
                             throws RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException
从接口 MQAdminExt 复制的描述
删除 broker 上的 topic 信息

指定者：
接口 MQAdminExt 中的 deleteTopicInNameServer
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

deleteSubscriptionGroup

public void deleteSubscriptionGroup(String addr,
                                    String groupName)
                             throws RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException
从接口 MQAdminExt 复制的描述
删除 broker 上的 subscription group 信息

指定者：
接口 MQAdminExt 中的 deleteSubscriptionGroup
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

createAndUpdateKvConfig

public void createAndUpdateKvConfig(String namespace,
                                    String key,
                                    String value)
                             throws RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException
从接口 MQAdminExt 复制的描述
在 namespace 上添加或者更新 KV 配置

指定者：
接口 MQAdminExt 中的 createAndUpdateKvConfig
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

deleteKvConfig

public void deleteKvConfig(String namespace,
                           String key)
                    throws RemotingException,
                           MQBrokerException,
                           InterruptedException,
                           MQClientException
从接口 MQAdminExt 复制的描述
删除 namespace 上的 KV 配置

指定者：
接口 MQAdminExt 中的 deleteKvConfig
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

getProjectGroupByIp

public String getProjectGroupByIp(String ip)
                           throws RemotingException,
                                  MQBrokerException,
                                  InterruptedException,
                                  MQClientException
从接口 MQAdminExt 复制的描述
通过 server ip 获取 project 信息

指定者：
接口 MQAdminExt 中的 getProjectGroupByIp
返回：
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

getIpsByProjectGroup

public String getIpsByProjectGroup(String projectGroup)
                            throws RemotingException,
                                   MQBrokerException,
                                   InterruptedException,
                                   MQClientException
从接口 MQAdminExt 复制的描述
通过 project 获取所有的 server ip 信息

指定者：
接口 MQAdminExt 中的 getIpsByProjectGroup
返回：
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

deleteIpsByProjectGroup

public void deleteIpsByProjectGroup(String projectGroup)
                             throws RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException
从接口 MQAdminExt 复制的描述
删除 project group 对应的所有 server ip

指定者：
接口 MQAdminExt 中的 deleteIpsByProjectGroup
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

resetOffsetByTimestampOld

public List<RollbackStats> resetOffsetByTimestampOld(String consumerGroup,
                                                     String topic,
                                                     long timestamp,
                                                     boolean force)
                                              throws RemotingException,
                                                     MQBrokerException,
                                                     InterruptedException,
                                                     MQClientException
从接口 MQAdminExt 复制的描述
按照时间回溯消费进度(客户端需要重启)

指定者：
接口 MQAdminExt 中的 resetOffsetByTimestampOld
返回：
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

getKVListByNamespace

public KVTable getKVListByNamespace(String namespace)
                             throws RemotingException,
                                    MQClientException,
                                    InterruptedException
从接口 MQAdminExt 复制的描述
获取指定Namespace下的所有kv

指定者：
接口 MQAdminExt 中的 getKVListByNamespace
返回：
抛出：
RemotingException
MQClientException
InterruptedException

updateBrokerConfig

public void updateBrokerConfig(String brokerAddr,
                               Properties properties)
                        throws RemotingConnectException,
                               RemotingSendRequestException,
                               RemotingTimeoutException,
                               UnsupportedEncodingException,
                               InterruptedException,
                               MQBrokerException
从接口 MQAdminExt 复制的描述
更新Broker配置

指定者：
接口 MQAdminExt 中的 updateBrokerConfig
抛出：
RemotingConnectException
RemotingSendRequestException
RemotingTimeoutException
UnsupportedEncodingException
InterruptedException
MQBrokerException

resetOffsetByTimestamp

public Map<MessageQueue,Long> resetOffsetByTimestamp(String topic,
                                                     String group,
                                                     long timestamp,
                                                     boolean isForce)
                                              throws RemotingException,
                                                     MQBrokerException,
                                                     InterruptedException,
                                                     MQClientException
从接口 MQAdminExt 复制的描述
按照时间回溯消费进度(客户端不需要重启)

指定者：
接口 MQAdminExt 中的 resetOffsetByTimestamp
返回：
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

getConsumeStatus

public Map<String,Map<MessageQueue,Long>> getConsumeStatus(String topic,
                                                           String group,
                                                           String clientAddr)
                                                    throws RemotingException,
                                                           MQBrokerException,
                                                           InterruptedException,
                                                           MQClientException
从接口 MQAdminExt 复制的描述
通过客户端查看消费者的消费情况

指定者：
接口 MQAdminExt 中的 getConsumeStatus
返回：
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

createOrUpdateOrderConf

public void createOrUpdateOrderConf(String key,
                                    String value,
                                    boolean isCluster)
                             throws RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException
从接口 MQAdminExt 复制的描述
创建或更新顺序消息的分区配置

指定者：
接口 MQAdminExt 中的 createOrUpdateOrderConf
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

queryTopicConsumeByWho

public GroupList queryTopicConsumeByWho(String topic)
                                 throws InterruptedException,
                                        MQBrokerException,
                                        RemotingException,
                                        MQClientException
从接口 MQAdminExt 复制的描述
根据Topic查询被哪些订阅组消费

指定者：
接口 MQAdminExt 中的 queryTopicConsumeByWho
返回：
抛出：
InterruptedException
MQBrokerException
RemotingTimeoutException
RemotingSendRequestException
RemotingConnectException
RemotingException
MQClientException

queryConsumeTimeSpan

public Set<QueueTimeSpan> queryConsumeTimeSpan(String topic,
                                               String group)
                                        throws InterruptedException,
                                               MQBrokerException,
                                               RemotingException,
                                               MQClientException
从接口 MQAdminExt 复制的描述
根据 topic 和 group 获取消息的时间跨度

指定者：
接口 MQAdminExt 中的 queryConsumeTimeSpan
返回：
抛出：
InterruptedException
MQBrokerException
RemotingConnectException
RemotingSendRequestException
RemotingTimeoutException
RemotingException
MQClientException

resetOffsetNew

public void resetOffsetNew(String consumerGroup,
                           String topic,
                           long timestamp)
                    throws RemotingException,
                           MQBrokerException,
                           InterruptedException,
                           MQClientException
从接口 MQAdminExt 复制的描述
重置消费进度，无论Consumer是否在线，都可以执行。不保证最终结果是否成功，需要调用方通过消费进度查询来再次确认

指定者：
接口 MQAdminExt 中的 resetOffsetNew
抛出：
RemotingException
MQBrokerException
InterruptedException
MQClientException

cleanExpiredConsumerQueue

public boolean cleanExpiredConsumerQueue(String cluster)
                                  throws RemotingConnectException,
                                         RemotingSendRequestException,
                                         RemotingTimeoutException,
                                         MQClientException,
                                         InterruptedException
从接口 MQAdminExt 复制的描述
触发清理失效的消费队列

指定者：
接口 MQAdminExt 中的 cleanExpiredConsumerQueue
参数：
cluster - null则表示所有集群
返回：
清理是否成功
抛出：
RemotingConnectException
RemotingSendRequestException
RemotingTimeoutException
MQClientException
InterruptedException

cleanExpiredConsumerQueueByAddr

public boolean cleanExpiredConsumerQueueByAddr(String addr)
                                        throws RemotingConnectException,
                                               RemotingSendRequestException,
                                               RemotingTimeoutException,
                                               MQClientException,
                                               InterruptedException
从接口 MQAdminExt 复制的描述
触发指定的broker清理失效的消费队列

指定者：
接口 MQAdminExt 中的 cleanExpiredConsumerQueueByAddr
返回：
清理是否成功
抛出：
RemotingConnectException
RemotingSendRequestException
RemotingTimeoutException
MQClientException
InterruptedException

getConsumerRunningInfo

public ConsumerRunningInfo getConsumerRunningInfo(String consumerGroup,
                                                  String clientId,
                                                  boolean jstack)
                                           throws RemotingException,
                                                  MQClientException,
                                                  InterruptedException
从接口 MQAdminExt 复制的描述
查询Consumer内存数据结构

指定者：
接口 MQAdminExt 中的 getConsumerRunningInfo
返回：
抛出：
RemotingException
MQClientException
InterruptedException

consumeMessageDirectly

public ConsumeMessageDirectlyResult consumeMessageDirectly(String consumerGroup,
                                                           String clientId,
                                                           String msgId)
                                                    throws RemotingException,
                                                           MQClientException,
                                                           InterruptedException,
                                                           MQBrokerException
从接口 MQAdminExt 复制的描述
向指定Consumer发送某条消息

指定者：
接口 MQAdminExt 中的 consumeMessageDirectly
返回：
抛出：
RemotingException
MQClientException
InterruptedException
MQBrokerException

messageTrackDetail

public List<MessageTrack> messageTrackDetail(MessageExt msg)
                                      throws RemotingException,
                                             MQClientException,
                                             InterruptedException,
                                             MQBrokerException
从接口 MQAdminExt 复制的描述
查询消息被谁消费了

指定者：
接口 MQAdminExt 中的 messageTrackDetail
返回：
抛出：
RemotingException
MQClientException
InterruptedException
MQBrokerException

cloneGroupOffset

public void cloneGroupOffset(String srcGroup,
                             String destGroup,
                             String topic,
                             boolean isOffline)
                      throws RemotingException,
                             MQClientException,
                             InterruptedException,
                             MQBrokerException
从接口 MQAdminExt 复制的描述
克隆某一个组的消费进度到新的组

指定者：
接口 MQAdminExt 中的 cloneGroupOffset
抛出：
RemotingException
MQClientException
InterruptedException
MQBrokerException

ViewBrokerStatsData

public BrokerStatsData ViewBrokerStatsData(String brokerAddr,
                                           String statsName,
                                           String statsKey)
                                    throws RemotingConnectException,
                                           RemotingSendRequestException,
                                           RemotingTimeoutException,
                                           MQClientException,
                                           InterruptedException
从接口 MQAdminExt 复制的描述
服务器统计数据输出

指定者：
接口 MQAdminExt 中的 ViewBrokerStatsData
返回：
抛出：
RemotingConnectException
RemotingSendRequestException
RemotingTimeoutException
MQClientException
InterruptedException
概述  软件包   类  使用  树  已过时  索引  帮助 
 上一个类   下一个类 框架    无框架    
摘要： 嵌套 | 字段 | 构造方法 | 方法 详细信息： 字段 | 构造方法 | 方法
Copyright © 2012-2015. All Rights Reserved.