@Test public void testCreatePlainAccessConfig_Success() throws InterruptedException, RemotingException, MQBrokerException { doAnswer(new Answer() { @Override public Object answer(InvocationOnMock mock) throws Throwable { RemotingCommand request = mock.getArgument(1); return createSuccessResponse4UpdateAclConfig(request); } }).when(remotingClient).invokeSync(anyString(), any(RemotingCommand.class), anyLong()); PlainAccessConfig config = createUpdateAclConfig(); try { mqClientAPI.createPlainAccessConfig(brokerAddr, config, 3 * 1000); } catch (MQClientException ex) { } }
public void createPlainAccessConfig(final String addr, final PlainAccessConfig plainAccessConfig, final long timeoutMillis) throws RemotingException, MQBrokerException, InterruptedException, MQClientException { CreateAccessConfigRequestHeader requestHeader = new CreateAccessConfigRequestHeader(); requestHeader.setAccessKey(plainAccessConfig.getAccessKey()); requestHeader.setSecretKey(plainAccessConfig.getSecretKey()); requestHeader.setAdmin(plainAccessConfig.isAdmin()); requestHeader.setDefaultGroupPerm(plainAccessConfig.getDefaultGroupPerm()); requestHeader.setDefaultTopicPerm(plainAccessConfig.getDefaultTopicPerm()); requestHeader.setWhiteRemoteAddress(plainAccessConfig.getWhiteRemoteAddress()); requestHeader.setTopicPerms(UtilAll.list2String(plainAccessConfig.getTopicPerms(), ",")); requestHeader.setGroupPerms(UtilAll.list2String(plainAccessConfig.getGroupPerms(), ",")); RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.UPDATE_AND_CREATE_ACL_CONFIG, requestHeader); RemotingCommand response = this.remotingClient.invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), addr), request, timeoutMillis); assert response != null; switch (response.getCode()) { case ResponseCode.SUCCESS: { return; } default: break; } throw new MQClientException(response.getCode(), response.getRemark()); }
MQClientAPIImpl { public void createPlainAccessConfig(final String addr, final PlainAccessConfig plainAccessConfig, final long timeoutMillis) throws RemotingException, MQBrokerException, InterruptedException, MQClientException { CreateAccessConfigRequestHeader requestHeader = new CreateAccessConfigRequestHeader(); requestHeader.setAccessKey(plainAccessConfig.getAccessKey()); requestHeader.setSecretKey(plainAccessConfig.getSecretKey()); requestHeader.setAdmin(plainAccessConfig.isAdmin()); requestHeader.setDefaultGroupPerm(plainAccessConfig.getDefaultGroupPerm()); requestHeader.setDefaultTopicPerm(plainAccessConfig.getDefaultTopicPerm()); requestHeader.setWhiteRemoteAddress(plainAccessConfig.getWhiteRemoteAddress()); requestHeader.setTopicPerms(UtilAll.list2String(plainAccessConfig.getTopicPerms(), ",")); requestHeader.setGroupPerms(UtilAll.list2String(plainAccessConfig.getGroupPerms(), ",")); RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.UPDATE_AND_CREATE_ACL_CONFIG, requestHeader); RemotingCommand response = this.remotingClient.invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), addr), request, timeoutMillis); assert response != null; switch (response.getCode()) { case ResponseCode.SUCCESS: { return; } default: break; } throw new MQClientException(response.getCode(), response.getRemark()); } }
MQClientAPIImpl { public void createPlainAccessConfig(final String addr, final PlainAccessConfig plainAccessConfig, final long timeoutMillis) throws RemotingException, MQBrokerException, InterruptedException, MQClientException { CreateAccessConfigRequestHeader requestHeader = new CreateAccessConfigRequestHeader(); requestHeader.setAccessKey(plainAccessConfig.getAccessKey()); requestHeader.setSecretKey(plainAccessConfig.getSecretKey()); requestHeader.setAdmin(plainAccessConfig.isAdmin()); requestHeader.setDefaultGroupPerm(plainAccessConfig.getDefaultGroupPerm()); requestHeader.setDefaultTopicPerm(plainAccessConfig.getDefaultTopicPerm()); requestHeader.setWhiteRemoteAddress(plainAccessConfig.getWhiteRemoteAddress()); requestHeader.setTopicPerms(UtilAll.list2String(plainAccessConfig.getTopicPerms(), ",")); requestHeader.setGroupPerms(UtilAll.list2String(plainAccessConfig.getGroupPerms(), ",")); RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.UPDATE_AND_CREATE_ACL_CONFIG, requestHeader); RemotingCommand response = this.remotingClient.invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), addr), request, timeoutMillis); assert response != null; switch (response.getCode()) { case ResponseCode.SUCCESS: { return; } default: break; } throw new MQClientException(response.getCode(), response.getRemark()); } MQClientAPIImpl(final NettyClientConfig nettyClientConfig,
        final ClientRemotingProcessor clientRemotingProcessor,
        RPCHook rpcHook, final ClientConfig clientConfig); }
MQClientAPIImpl { public void createPlainAccessConfig(final String addr, final PlainAccessConfig plainAccessConfig, final long timeoutMillis) throws RemotingException, MQBrokerException, InterruptedException, MQClientException { CreateAccessConfigRequestHeader requestHeader = new CreateAccessConfigRequestHeader(); requestHeader.setAccessKey(plainAccessConfig.getAccessKey()); requestHeader.setSecretKey(plainAccessConfig.getSecretKey()); requestHeader.setAdmin(plainAccessConfig.isAdmin()); requestHeader.setDefaultGroupPerm(plainAccessConfig.getDefaultGroupPerm()); requestHeader.setDefaultTopicPerm(plainAccessConfig.getDefaultTopicPerm()); requestHeader.setWhiteRemoteAddress(plainAccessConfig.getWhiteRemoteAddress()); requestHeader.setTopicPerms(UtilAll.list2String(plainAccessConfig.getTopicPerms(), ",")); requestHeader.setGroupPerms(UtilAll.list2String(plainAccessConfig.getGroupPerms(), ",")); RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.UPDATE_AND_CREATE_ACL_CONFIG, requestHeader); RemotingCommand response = this.remotingClient.invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), addr), request, timeoutMillis); assert response != null; switch (response.getCode()) { case ResponseCode.SUCCESS: { return; } default: break; } throw new MQClientException(response.getCode(), response.getRemark()); } MQClientAPIImpl(final NettyClientConfig nettyClientConfig,
        final ClientRemotingProcessor clientRemotingProcessor,
        RPCHook rpcHook, final ClientConfig clientConfig); List<String> getNameServerAddressList(); RemotingClient getRemotingClient(); String fetchNameServerAddr(); void updateNameServerAddressList(final String addrs); void start(); void shutdown(); void createSubscriptionGroup(final String addr, final SubscriptionGroupConfig config,
        final long timeoutMillis); void createTopic(final String addr, final String defaultTopic, final TopicConfig topicConfig,
        final long timeoutMillis); void createPlainAccessConfig(final String addr, final PlainAccessConfig plainAccessConfig,
        final long timeoutMillis); void deleteAccessConfig(final String addr, final String accessKey, final long timeoutMillis); void updateGlobalWhiteAddrsConfig(final String addr, final String globalWhiteAddrs, final long timeoutMillis); ClusterAclVersionInfo getBrokerClusterAclInfo(final String addr,
        final long timeoutMillis); AclConfig getBrokerClusterConfig(final String addr, final long timeoutMillis); SendResult sendMessage(
        final String addr,
        final String brokerName,
        final Message msg,
        final SendMessageRequestHeader requestHeader,
        final long timeoutMillis,
        final CommunicationMode communicationMode,
        final SendMessageContext context,
        final DefaultMQProducerImpl producer
    ); SendResult sendMessage(
        final String addr,
        final String brokerName,
        final Message msg,
        final SendMessageRequestHeader requestHeader,
        final long timeoutMillis,
        final CommunicationMode communicationMode,
        final SendCallback sendCallback,
        final TopicPublishInfo topicPublishInfo,
        final MQClientInstance instance,
        final int retryTimesWhenSendFailed,
        final SendMessageContext context,
        final DefaultMQProducerImpl producer
    ); PullResult pullMessage(
        final String addr,
        final PullMessageRequestHeader requestHeader,
        final long timeoutMillis,
        final CommunicationMode communicationMode,
        final PullCallback pullCallback
    ); MessageExt viewMessage(final String addr, final long phyoffset, final long timeoutMillis); long searchOffset(final String addr, final String topic, final int queueId, final long timestamp,
        final long timeoutMillis); long getMaxOffset(final String addr, final String topic, final int queueId, final long timeoutMillis); List<String> getConsumerIdListByGroup(
        final String addr,
        final String consumerGroup,
        final long timeoutMillis); long getMinOffset(final String addr, final String topic, final int queueId, final long timeoutMillis); long getEarliestMsgStoretime(final String addr, final String topic, final int queueId,
        final long timeoutMillis); long queryConsumerOffset(
        final String addr,
        final QueryConsumerOffsetRequestHeader requestHeader,
        final long timeoutMillis
    ); void updateConsumerOffset(
        final String addr,
        final UpdateConsumerOffsetRequestHeader requestHeader,
        final long timeoutMillis
    ); void updateConsumerOffsetOneway(
        final String addr,
        final UpdateConsumerOffsetRequestHeader requestHeader,
        final long timeoutMillis
    ); int sendHearbeat(
        final String addr,
        final HeartbeatData heartbeatData,
        final long timeoutMillis
    ); void unregisterClient(
        final String addr,
        final String clientID,
        final String producerGroup,
        final String consumerGroup,
        final long timeoutMillis
    ); void endTransactionOneway(
        final String addr,
        final EndTransactionRequestHeader requestHeader,
        final String remark,
        final long timeoutMillis
    ); void queryMessage(
        final String addr,
        final QueryMessageRequestHeader requestHeader,
        final long timeoutMillis,
        final InvokeCallback invokeCallback,
        final Boolean isUnqiueKey
    ); boolean registerClient(final String addr, final HeartbeatData heartbeat, final long timeoutMillis); void consumerSendMessageBack(
        final String addr,
        final MessageExt msg,
        final String consumerGroup,
        final int delayLevel,
        final long timeoutMillis,
        final int maxConsumeRetryTimes
    ); Set<MessageQueue> lockBatchMQ(
        final String addr,
        final LockBatchRequestBody requestBody,
        final long timeoutMillis); void unlockBatchMQ(
        final String addr,
        final UnlockBatchRequestBody requestBody,
        final long timeoutMillis,
        final boolean oneway
    ); TopicStatsTable getTopicStatsInfo(final String addr, final String topic,
        final long timeoutMillis); ConsumeStats getConsumeStats(final String addr, final String consumerGroup, final long timeoutMillis); ConsumeStats getConsumeStats(final String addr, final String consumerGroup, final String topic,
        final long timeoutMillis); ProducerConnection getProducerConnectionList(final String addr, final String producerGroup,
        final long timeoutMillis); ConsumerConnection getConsumerConnectionList(final String addr, final String consumerGroup,
        final long timeoutMillis); KVTable getBrokerRuntimeInfo(final String addr, final long timeoutMillis); void updateBrokerConfig(final String addr, final Properties properties, final long timeoutMillis); Properties getBrokerConfig(final String addr, final long timeoutMillis); ClusterInfo getBrokerClusterInfo(
        final long timeoutMillis); TopicRouteData getDefaultTopicRouteInfoFromNameServer(final String topic, final long timeoutMillis); TopicRouteData getTopicRouteInfoFromNameServer(final String topic, final long timeoutMillis); TopicRouteData getTopicRouteInfoFromNameServer(final String topic, final long timeoutMillis,
        boolean allowTopicNotExist); TopicList getTopicListFromNameServer(final long timeoutMillis); int wipeWritePermOfBroker(final String namesrvAddr, String brokerName,
        final long timeoutMillis); void deleteTopicInBroker(final String addr, final String topic, final long timeoutMillis); void deleteTopicInNameServer(final String addr, final String topic, final long timeoutMillis); void deleteSubscriptionGroup(final String addr, final String groupName, final long timeoutMillis); String getKVConfigValue(final String namespace, final String key, final long timeoutMillis); void putKVConfigValue(final String namespace, final String key, final String value, final long timeoutMillis); void deleteKVConfigValue(final String namespace, final String key, final long timeoutMillis); KVTable getKVListByNamespace(final String namespace, final long timeoutMillis); Map<MessageQueue, Long> invokeBrokerToResetOffset(final String addr, final String topic, final String group,
        final long timestamp, final boolean isForce, final long timeoutMillis); Map<MessageQueue, Long> invokeBrokerToResetOffset(final String addr, final String topic, final String group,
        final long timestamp, final boolean isForce, final long timeoutMillis, boolean isC); Map<String, Map<MessageQueue, Long>> invokeBrokerToGetConsumerStatus(final String addr, final String topic,
        final String group,
        final String clientAddr,
        final long timeoutMillis); GroupList queryTopicConsumeByWho(final String addr, final String topic, final long timeoutMillis); List<QueueTimeSpan> queryConsumeTimeSpan(final String addr, final String topic, final String group,
        final long timeoutMillis); TopicList getTopicsByCluster(final String cluster, final long timeoutMillis); void registerMessageFilterClass(final String addr,
        final String consumerGroup,
        final String topic,
        final String className,
        final int classCRC,
        final byte[] classBody,
        final long timeoutMillis); TopicList getSystemTopicList(
        final long timeoutMillis); TopicList getSystemTopicListFromBroker(final String addr, final long timeoutMillis); boolean cleanExpiredConsumeQueue(final String addr,
        long timeoutMillis); boolean cleanUnusedTopicByAddr(final String addr,
        long timeoutMillis); ConsumerRunningInfo getConsumerRunningInfo(final String addr, String consumerGroup, String clientId,
        boolean jstack,
        final long timeoutMillis); ConsumeMessageDirectlyResult consumeMessageDirectly(final String addr,
        String consumerGroup,
        String clientId,
        String msgId,
        final long timeoutMillis); Map<Integer, Long> queryCorrectionOffset(final String addr, final String topic, final String group,
        Set<String> filterGroup,
        long timeoutMillis); TopicList getUnitTopicList(final boolean containRetry, final long timeoutMillis); TopicList getHasUnitSubTopicList(final boolean containRetry, final long timeoutMillis); TopicList getHasUnitSubUnUnitTopicList(final boolean containRetry, final long timeoutMillis); void cloneGroupOffset(final String addr, final String srcGroup, final String destGroup, final String topic,
        final boolean isOffline,
        final long timeoutMillis); BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey, long timeoutMillis); Set<String> getClusterList(String topic,
        long timeoutMillis); ConsumeStatsList fetchConsumeStatsInBroker(String brokerAddr, boolean isOrder,
        long timeoutMillis); SubscriptionGroupWrapper getAllSubscriptionGroup(final String brokerAddr,
        long timeoutMillis); TopicConfigSerializeWrapper getAllTopicConfig(final String addr,
        long timeoutMillis); void updateNameServerConfig(final Properties properties, final List<String> nameServers, long timeoutMillis); Map<String, Properties> getNameServerConfig(final List<String> nameServers, long timeoutMillis); QueryConsumeQueueResponseBody queryConsumeQueue(final String brokerAddr, final String topic,
        final int queueId,
        final long index, final int count, final String consumerGroup,
        final long timeoutMillis); void checkClientInBroker(final String brokerAddr, final String consumerGroup,
        final String clientId, final SubscriptionData subscriptionData,
        final long timeoutMillis); boolean resumeCheckHalfMessage(final String addr, String msgId,
        final long timeoutMillis); }
MQClientAPIImpl { public void createPlainAccessConfig(final String addr, final PlainAccessConfig plainAccessConfig, final long timeoutMillis) throws RemotingException, MQBrokerException, InterruptedException, MQClientException { CreateAccessConfigRequestHeader requestHeader = new CreateAccessConfigRequestHeader(); requestHeader.setAccessKey(plainAccessConfig.getAccessKey()); requestHeader.setSecretKey(plainAccessConfig.getSecretKey()); requestHeader.setAdmin(plainAccessConfig.isAdmin()); requestHeader.setDefaultGroupPerm(plainAccessConfig.getDefaultGroupPerm()); requestHeader.setDefaultTopicPerm(plainAccessConfig.getDefaultTopicPerm()); requestHeader.setWhiteRemoteAddress(plainAccessConfig.getWhiteRemoteAddress()); requestHeader.setTopicPerms(UtilAll.list2String(plainAccessConfig.getTopicPerms(), ",")); requestHeader.setGroupPerms(UtilAll.list2String(plainAccessConfig.getGroupPerms(), ",")); RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.UPDATE_AND_CREATE_ACL_CONFIG, requestHeader); RemotingCommand response = this.remotingClient.invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), addr), request, timeoutMillis); assert response != null; switch (response.getCode()) { case ResponseCode.SUCCESS: { return; } default: break; } throw new MQClientException(response.getCode(), response.getRemark()); } MQClientAPIImpl(final NettyClientConfig nettyClientConfig,
        final ClientRemotingProcessor clientRemotingProcessor,
        RPCHook rpcHook, final ClientConfig clientConfig); List<String> getNameServerAddressList(); RemotingClient getRemotingClient(); String fetchNameServerAddr(); void updateNameServerAddressList(final String addrs); void start(); void shutdown(); void createSubscriptionGroup(final String addr, final SubscriptionGroupConfig config,
        final long timeoutMillis); void createTopic(final String addr, final String defaultTopic, final TopicConfig topicConfig,
        final long timeoutMillis); void createPlainAccessConfig(final String addr, final PlainAccessConfig plainAccessConfig,
        final long timeoutMillis); void deleteAccessConfig(final String addr, final String accessKey, final long timeoutMillis); void updateGlobalWhiteAddrsConfig(final String addr, final String globalWhiteAddrs, final long timeoutMillis); ClusterAclVersionInfo getBrokerClusterAclInfo(final String addr,
        final long timeoutMillis); AclConfig getBrokerClusterConfig(final String addr, final long timeoutMillis); SendResult sendMessage(
        final String addr,
        final String brokerName,
        final Message msg,
        final SendMessageRequestHeader requestHeader,
        final long timeoutMillis,
        final CommunicationMode communicationMode,
        final SendMessageContext context,
        final DefaultMQProducerImpl producer
    ); SendResult sendMessage(
        final String addr,
        final String brokerName,
        final Message msg,
        final SendMessageRequestHeader requestHeader,
        final long timeoutMillis,
        final CommunicationMode communicationMode,
        final SendCallback sendCallback,
        final TopicPublishInfo topicPublishInfo,
        final MQClientInstance instance,
        final int retryTimesWhenSendFailed,
        final SendMessageContext context,
        final DefaultMQProducerImpl producer
    ); PullResult pullMessage(
        final String addr,
        final PullMessageRequestHeader requestHeader,
        final long timeoutMillis,
        final CommunicationMode communicationMode,
        final PullCallback pullCallback
    ); MessageExt viewMessage(final String addr, final long phyoffset, final long timeoutMillis); long searchOffset(final String addr, final String topic, final int queueId, final long timestamp,
        final long timeoutMillis); long getMaxOffset(final String addr, final String topic, final int queueId, final long timeoutMillis); List<String> getConsumerIdListByGroup(
        final String addr,
        final String consumerGroup,
        final long timeoutMillis); long getMinOffset(final String addr, final String topic, final int queueId, final long timeoutMillis); long getEarliestMsgStoretime(final String addr, final String topic, final int queueId,
        final long timeoutMillis); long queryConsumerOffset(
        final String addr,
        final QueryConsumerOffsetRequestHeader requestHeader,
        final long timeoutMillis
    ); void updateConsumerOffset(
        final String addr,
        final UpdateConsumerOffsetRequestHeader requestHeader,
        final long timeoutMillis
    ); void updateConsumerOffsetOneway(
        final String addr,
        final UpdateConsumerOffsetRequestHeader requestHeader,
        final long timeoutMillis
    ); int sendHearbeat(
        final String addr,
        final HeartbeatData heartbeatData,
        final long timeoutMillis
    ); void unregisterClient(
        final String addr,
        final String clientID,
        final String producerGroup,
        final String consumerGroup,
        final long timeoutMillis
    ); void endTransactionOneway(
        final String addr,
        final EndTransactionRequestHeader requestHeader,
        final String remark,
        final long timeoutMillis
    ); void queryMessage(
        final String addr,
        final QueryMessageRequestHeader requestHeader,
        final long timeoutMillis,
        final InvokeCallback invokeCallback,
        final Boolean isUnqiueKey
    ); boolean registerClient(final String addr, final HeartbeatData heartbeat, final long timeoutMillis); void consumerSendMessageBack(
        final String addr,
        final MessageExt msg,
        final String consumerGroup,
        final int delayLevel,
        final long timeoutMillis,
        final int maxConsumeRetryTimes
    ); Set<MessageQueue> lockBatchMQ(
        final String addr,
        final LockBatchRequestBody requestBody,
        final long timeoutMillis); void unlockBatchMQ(
        final String addr,
        final UnlockBatchRequestBody requestBody,
        final long timeoutMillis,
        final boolean oneway
    ); TopicStatsTable getTopicStatsInfo(final String addr, final String topic,
        final long timeoutMillis); ConsumeStats getConsumeStats(final String addr, final String consumerGroup, final long timeoutMillis); ConsumeStats getConsumeStats(final String addr, final String consumerGroup, final String topic,
        final long timeoutMillis); ProducerConnection getProducerConnectionList(final String addr, final String producerGroup,
        final long timeoutMillis); ConsumerConnection getConsumerConnectionList(final String addr, final String consumerGroup,
        final long timeoutMillis); KVTable getBrokerRuntimeInfo(final String addr, final long timeoutMillis); void updateBrokerConfig(final String addr, final Properties properties, final long timeoutMillis); Properties getBrokerConfig(final String addr, final long timeoutMillis); ClusterInfo getBrokerClusterInfo(
        final long timeoutMillis); TopicRouteData getDefaultTopicRouteInfoFromNameServer(final String topic, final long timeoutMillis); TopicRouteData getTopicRouteInfoFromNameServer(final String topic, final long timeoutMillis); TopicRouteData getTopicRouteInfoFromNameServer(final String topic, final long timeoutMillis,
        boolean allowTopicNotExist); TopicList getTopicListFromNameServer(final long timeoutMillis); int wipeWritePermOfBroker(final String namesrvAddr, String brokerName,
        final long timeoutMillis); void deleteTopicInBroker(final String addr, final String topic, final long timeoutMillis); void deleteTopicInNameServer(final String addr, final String topic, final long timeoutMillis); void deleteSubscriptionGroup(final String addr, final String groupName, final long timeoutMillis); String getKVConfigValue(final String namespace, final String key, final long timeoutMillis); void putKVConfigValue(final String namespace, final String key, final String value, final long timeoutMillis); void deleteKVConfigValue(final String namespace, final String key, final long timeoutMillis); KVTable getKVListByNamespace(final String namespace, final long timeoutMillis); Map<MessageQueue, Long> invokeBrokerToResetOffset(final String addr, final String topic, final String group,
        final long timestamp, final boolean isForce, final long timeoutMillis); Map<MessageQueue, Long> invokeBrokerToResetOffset(final String addr, final String topic, final String group,
        final long timestamp, final boolean isForce, final long timeoutMillis, boolean isC); Map<String, Map<MessageQueue, Long>> invokeBrokerToGetConsumerStatus(final String addr, final String topic,
        final String group,
        final String clientAddr,
        final long timeoutMillis); GroupList queryTopicConsumeByWho(final String addr, final String topic, final long timeoutMillis); List<QueueTimeSpan> queryConsumeTimeSpan(final String addr, final String topic, final String group,
        final long timeoutMillis); TopicList getTopicsByCluster(final String cluster, final long timeoutMillis); void registerMessageFilterClass(final String addr,
        final String consumerGroup,
        final String topic,
        final String className,
        final int classCRC,
        final byte[] classBody,
        final long timeoutMillis); TopicList getSystemTopicList(
        final long timeoutMillis); TopicList getSystemTopicListFromBroker(final String addr, final long timeoutMillis); boolean cleanExpiredConsumeQueue(final String addr,
        long timeoutMillis); boolean cleanUnusedTopicByAddr(final String addr,
        long timeoutMillis); ConsumerRunningInfo getConsumerRunningInfo(final String addr, String consumerGroup, String clientId,
        boolean jstack,
        final long timeoutMillis); ConsumeMessageDirectlyResult consumeMessageDirectly(final String addr,
        String consumerGroup,
        String clientId,
        String msgId,
        final long timeoutMillis); Map<Integer, Long> queryCorrectionOffset(final String addr, final String topic, final String group,
        Set<String> filterGroup,
        long timeoutMillis); TopicList getUnitTopicList(final boolean containRetry, final long timeoutMillis); TopicList getHasUnitSubTopicList(final boolean containRetry, final long timeoutMillis); TopicList getHasUnitSubUnUnitTopicList(final boolean containRetry, final long timeoutMillis); void cloneGroupOffset(final String addr, final String srcGroup, final String destGroup, final String topic,
        final boolean isOffline,
        final long timeoutMillis); BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName, String statsKey, long timeoutMillis); Set<String> getClusterList(String topic,
        long timeoutMillis); ConsumeStatsList fetchConsumeStatsInBroker(String brokerAddr, boolean isOrder,
        long timeoutMillis); SubscriptionGroupWrapper getAllSubscriptionGroup(final String brokerAddr,
        long timeoutMillis); TopicConfigSerializeWrapper getAllTopicConfig(final String addr,
        long timeoutMillis); void updateNameServerConfig(final Properties properties, final List<String> nameServers, long timeoutMillis); Map<String, Properties> getNameServerConfig(final List<String> nameServers, long timeoutMillis); QueryConsumeQueueResponseBody queryConsumeQueue(final String brokerAddr, final String topic,
        final int queueId,
        final long index, final int count, final String consumerGroup,
        final long timeoutMillis); void checkClientInBroker(final String brokerAddr, final String consumerGroup,
        final String clientId, final SubscriptionData subscriptionData,
        final long timeoutMillis); boolean resumeCheckHalfMessage(final String addr, String msgId,
        final long timeoutMillis);  }