@Test public void testPutKVConfig() throws RemotingException, MQClientException, InterruptedException { String topicConfig = defaultMQAdminExt.getKVConfig(NamesrvUtil.NAMESPACE_ORDER_TOPIC_CONFIG, "UnitTest"); assertThat(topicConfig).isEqualTo("topicListConfig"); KVTable kvs = defaultMQAdminExt.getKVListByNamespace(NamesrvUtil.NAMESPACE_ORDER_TOPIC_CONFIG); assertThat(kvs.getTable().get("broker-name")).isEqualTo("broker-one"); assertThat(kvs.getTable().get("cluster-name")).isEqualTo("default-cluster"); }
@Override public void putKVConfig(String namespace, String key, String value) { defaultMQAdminExtImpl.putKVConfig(namespace, key, value); }
DefaultMQAdminExt extends ClientConfig implements MQAdminExt { @Override public void putKVConfig(String namespace, String key, String value) { defaultMQAdminExtImpl.putKVConfig(namespace, key, value); } }
DefaultMQAdminExt extends ClientConfig implements MQAdminExt { @Override public void putKVConfig(String namespace, String key, String value) { defaultMQAdminExtImpl.putKVConfig(namespace, key, value); } DefaultMQAdminExt();  DefaultMQAdminExt(long timeoutMillis);  DefaultMQAdminExt(RPCHook rpcHook);  DefaultMQAdminExt(RPCHook rpcHook, long timeoutMillis);  DefaultMQAdminExt(final String adminExtGroup);  DefaultMQAdminExt(final String adminExtGroup, long timeoutMillis); }
DefaultMQAdminExt extends ClientConfig implements MQAdminExt { @Override public void putKVConfig(String namespace, String key, String value) { defaultMQAdminExtImpl.putKVConfig(namespace, key, value); } DefaultMQAdminExt();  DefaultMQAdminExt(long timeoutMillis);  DefaultMQAdminExt(RPCHook rpcHook);  DefaultMQAdminExt(RPCHook rpcHook, long timeoutMillis);  DefaultMQAdminExt(final String adminExtGroup);  DefaultMQAdminExt(final String adminExtGroup, long timeoutMillis); @Override void createTopic(String key, String newTopic, int queueNum); @Override void createTopic(String key, String newTopic, int queueNum, int topicSysFlag); @Override long searchOffset(MessageQueue mq, long timestamp); @Override long maxOffset(MessageQueue mq); @Override long minOffset(MessageQueue mq); @Override long earliestMsgStoreTime(MessageQueue mq); @Override MessageExt viewMessage(
        String offsetMsgId); @Override QueryResult queryMessage(String topic, String key, int maxNum, long begin,
        long end); @Override void start(); @Override void shutdown(); @Override void updateBrokerConfig(String brokerAddr,
        Properties properties); @Override Properties getBrokerConfig(final String brokerAddr); @Override void createAndUpdateTopicConfig(String addr, TopicConfig config); @Override void createAndUpdatePlainAccessConfig(String addr,
        PlainAccessConfig config); @Override void deletePlainAccessConfig(String addr,
        String accessKey); @Override void updateGlobalWhiteAddrConfig(String addr,
        String globalWhiteAddrs); @Override ClusterAclVersionInfo examineBrokerClusterAclVersionInfo(
        String addr); @Override AclConfig examineBrokerClusterAclConfig(
        String addr); @Override void createAndUpdateSubscriptionGroupConfig(String addr,
        SubscriptionGroupConfig config); @Override SubscriptionGroupConfig examineSubscriptionGroupConfig(String addr, String group); @Override TopicConfig examineTopicConfig(String addr, String topic); @Override TopicStatsTable examineTopicStats(
        String topic); @Override TopicList fetchAllTopicList(); @Override TopicList fetchTopicsByCLuster(
        String clusterName); @Override KVTable fetchBrokerRuntimeStats(
        final String brokerAddr); @Override ConsumeStats examineConsumeStats(
        String consumerGroup); @Override ConsumeStats examineConsumeStats(String consumerGroup,
        String topic); @Override ClusterInfo examineBrokerClusterInfo(); @Override TopicRouteData examineTopicRouteInfo(
        String topic); @Override ConsumerConnection examineConsumerConnectionInfo(
        String consumerGroup); @Override ProducerConnection examineProducerConnectionInfo(String producerGroup,
        final String topic); @Override List<String> getNameServerAddressList(); @Override int wipeWritePermOfBroker(final String namesrvAddr, String brokerName); @Override void putKVConfig(String namespace, String key, String value); @Override String getKVConfig(String namespace,
        String key); @Override KVTable getKVListByNamespace(
        String namespace); @Override void deleteTopicInBroker(Set<String> addrs,
        String topic); @Override void deleteTopicInNameServer(Set<String> addrs,
        String topic); @Override void deleteSubscriptionGroup(String addr,
        String groupName); @Override void createAndUpdateKvConfig(String namespace, String key,
        String value); @Override void deleteKvConfig(String namespace,
        String key); @Override List<RollbackStats> resetOffsetByTimestampOld(String consumerGroup, String topic, long timestamp,
        boolean force); @Override Map<MessageQueue, Long> resetOffsetByTimestamp(String topic, String group, long timestamp, boolean isForce); Map<MessageQueue, Long> resetOffsetByTimestamp(String topic, String group, long timestamp, boolean isForce,
        boolean isC); @Override void resetOffsetNew(String consumerGroup, String topic,
        long timestamp); @Override Map<String, Map<MessageQueue, Long>> getConsumeStatus(String topic, String group,
        String clientAddr); @Override void createOrUpdateOrderConf(String key, String value,
        boolean isCluster); @Override GroupList queryTopicConsumeByWho(
        String topic); @Override List<QueueTimeSpan> queryConsumeTimeSpan(final String topic,
        final String group); @Override boolean cleanExpiredConsumerQueue(
        String cluster); @Override boolean cleanExpiredConsumerQueueByAddr(
        String addr); @Override boolean cleanUnusedTopic(String cluster); @Override boolean cleanUnusedTopicByAddr(String addr); @Override ConsumerRunningInfo getConsumerRunningInfo(String consumerGroup, String clientId,
        boolean jstack); @Override ConsumeMessageDirectlyResult consumeMessageDirectly(String consumerGroup, String clientId, String msgId); @Override ConsumeMessageDirectlyResult consumeMessageDirectly(final String consumerGroup, final String clientId,
        final String topic,
        final String msgId); @Override List<MessageTrack> messageTrackDetail(
        MessageExt msg); @Override void cloneGroupOffset(String srcGroup, String destGroup, String topic,
        boolean isOffline); @Override BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
        String statsKey); @Override Set<String> getClusterList(String topic); @Override ConsumeStatsList fetchConsumeStatsInBroker(final String brokerAddr, boolean isOrder,
        long timeoutMillis); @Override Set<String> getTopicClusterList(
        final String topic); @Override SubscriptionGroupWrapper getAllSubscriptionGroup(final String brokerAddr,
        long timeoutMillis); @Override TopicConfigSerializeWrapper getAllTopicGroup(final String brokerAddr,
        long timeoutMillis); @Override MessageExt viewMessage(String topic, String msgId); String getAdminExtGroup(); void setAdminExtGroup(String adminExtGroup); String getCreateTopicKey(); void setCreateTopicKey(String createTopicKey); @Override void updateConsumeOffset(String brokerAddr, String consumeGroup, MessageQueue mq,
        long offset); @Override void updateNameServerConfig(final Properties properties, final List<String> nameServers); @Override Map<String, Properties> getNameServerConfig(final List<String> nameServers); @Override QueryConsumeQueueResponseBody queryConsumeQueue(String brokerAddr, String topic, int queueId, long index,
        int count, String consumerGroup); @Override boolean resumeCheckHalfMessage(String msgId); @Override boolean resumeCheckHalfMessage(String topic,
            String msgId); }
DefaultMQAdminExt extends ClientConfig implements MQAdminExt { @Override public void putKVConfig(String namespace, String key, String value) { defaultMQAdminExtImpl.putKVConfig(namespace, key, value); } DefaultMQAdminExt();  DefaultMQAdminExt(long timeoutMillis);  DefaultMQAdminExt(RPCHook rpcHook);  DefaultMQAdminExt(RPCHook rpcHook, long timeoutMillis);  DefaultMQAdminExt(final String adminExtGroup);  DefaultMQAdminExt(final String adminExtGroup, long timeoutMillis); @Override void createTopic(String key, String newTopic, int queueNum); @Override void createTopic(String key, String newTopic, int queueNum, int topicSysFlag); @Override long searchOffset(MessageQueue mq, long timestamp); @Override long maxOffset(MessageQueue mq); @Override long minOffset(MessageQueue mq); @Override long earliestMsgStoreTime(MessageQueue mq); @Override MessageExt viewMessage(
        String offsetMsgId); @Override QueryResult queryMessage(String topic, String key, int maxNum, long begin,
        long end); @Override void start(); @Override void shutdown(); @Override void updateBrokerConfig(String brokerAddr,
        Properties properties); @Override Properties getBrokerConfig(final String brokerAddr); @Override void createAndUpdateTopicConfig(String addr, TopicConfig config); @Override void createAndUpdatePlainAccessConfig(String addr,
        PlainAccessConfig config); @Override void deletePlainAccessConfig(String addr,
        String accessKey); @Override void updateGlobalWhiteAddrConfig(String addr,
        String globalWhiteAddrs); @Override ClusterAclVersionInfo examineBrokerClusterAclVersionInfo(
        String addr); @Override AclConfig examineBrokerClusterAclConfig(
        String addr); @Override void createAndUpdateSubscriptionGroupConfig(String addr,
        SubscriptionGroupConfig config); @Override SubscriptionGroupConfig examineSubscriptionGroupConfig(String addr, String group); @Override TopicConfig examineTopicConfig(String addr, String topic); @Override TopicStatsTable examineTopicStats(
        String topic); @Override TopicList fetchAllTopicList(); @Override TopicList fetchTopicsByCLuster(
        String clusterName); @Override KVTable fetchBrokerRuntimeStats(
        final String brokerAddr); @Override ConsumeStats examineConsumeStats(
        String consumerGroup); @Override ConsumeStats examineConsumeStats(String consumerGroup,
        String topic); @Override ClusterInfo examineBrokerClusterInfo(); @Override TopicRouteData examineTopicRouteInfo(
        String topic); @Override ConsumerConnection examineConsumerConnectionInfo(
        String consumerGroup); @Override ProducerConnection examineProducerConnectionInfo(String producerGroup,
        final String topic); @Override List<String> getNameServerAddressList(); @Override int wipeWritePermOfBroker(final String namesrvAddr, String brokerName); @Override void putKVConfig(String namespace, String key, String value); @Override String getKVConfig(String namespace,
        String key); @Override KVTable getKVListByNamespace(
        String namespace); @Override void deleteTopicInBroker(Set<String> addrs,
        String topic); @Override void deleteTopicInNameServer(Set<String> addrs,
        String topic); @Override void deleteSubscriptionGroup(String addr,
        String groupName); @Override void createAndUpdateKvConfig(String namespace, String key,
        String value); @Override void deleteKvConfig(String namespace,
        String key); @Override List<RollbackStats> resetOffsetByTimestampOld(String consumerGroup, String topic, long timestamp,
        boolean force); @Override Map<MessageQueue, Long> resetOffsetByTimestamp(String topic, String group, long timestamp, boolean isForce); Map<MessageQueue, Long> resetOffsetByTimestamp(String topic, String group, long timestamp, boolean isForce,
        boolean isC); @Override void resetOffsetNew(String consumerGroup, String topic,
        long timestamp); @Override Map<String, Map<MessageQueue, Long>> getConsumeStatus(String topic, String group,
        String clientAddr); @Override void createOrUpdateOrderConf(String key, String value,
        boolean isCluster); @Override GroupList queryTopicConsumeByWho(
        String topic); @Override List<QueueTimeSpan> queryConsumeTimeSpan(final String topic,
        final String group); @Override boolean cleanExpiredConsumerQueue(
        String cluster); @Override boolean cleanExpiredConsumerQueueByAddr(
        String addr); @Override boolean cleanUnusedTopic(String cluster); @Override boolean cleanUnusedTopicByAddr(String addr); @Override ConsumerRunningInfo getConsumerRunningInfo(String consumerGroup, String clientId,
        boolean jstack); @Override ConsumeMessageDirectlyResult consumeMessageDirectly(String consumerGroup, String clientId, String msgId); @Override ConsumeMessageDirectlyResult consumeMessageDirectly(final String consumerGroup, final String clientId,
        final String topic,
        final String msgId); @Override List<MessageTrack> messageTrackDetail(
        MessageExt msg); @Override void cloneGroupOffset(String srcGroup, String destGroup, String topic,
        boolean isOffline); @Override BrokerStatsData viewBrokerStatsData(String brokerAddr, String statsName,
        String statsKey); @Override Set<String> getClusterList(String topic); @Override ConsumeStatsList fetchConsumeStatsInBroker(final String brokerAddr, boolean isOrder,
        long timeoutMillis); @Override Set<String> getTopicClusterList(
        final String topic); @Override SubscriptionGroupWrapper getAllSubscriptionGroup(final String brokerAddr,
        long timeoutMillis); @Override TopicConfigSerializeWrapper getAllTopicGroup(final String brokerAddr,
        long timeoutMillis); @Override MessageExt viewMessage(String topic, String msgId); String getAdminExtGroup(); void setAdminExtGroup(String adminExtGroup); String getCreateTopicKey(); void setCreateTopicKey(String createTopicKey); @Override void updateConsumeOffset(String brokerAddr, String consumeGroup, MessageQueue mq,
        long offset); @Override void updateNameServerConfig(final Properties properties, final List<String> nameServers); @Override Map<String, Properties> getNameServerConfig(final List<String> nameServers); @Override QueryConsumeQueueResponseBody queryConsumeQueue(String brokerAddr, String topic, int queueId, long index,
        int count, String consumerGroup); @Override boolean resumeCheckHalfMessage(String msgId); @Override boolean resumeCheckHalfMessage(String topic,
            String msgId);  }