Nov 7, 2025
diff --git a/tools/src/test/java/org/apache/rocketmq/tools/command/CommandUtilTest.java b/tools/src/test/java/org/apache/rocketmq/tools/command/CommandUtilTest.java
 import org.junit.Test;

 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static org.mockito.ArgumentMatchers.anyLong;
 import static org.mockito.ArgumentMatchers.anyString;
 import static org.mockito.Mockito.mock;
        assertThat(result.size()).isEqualTo(0);
    }

    @Test
    public void testFetchMasterAndSlaveAddrByClusterName() throws InterruptedException, MQBrokerException, RemotingTimeoutException, RemotingSendRequestException, RemotingConnectException {
        Set<String> result = CommandUtil.fetchMasterAndSlaveAddrByClusterName(defaultMQAdminExtImpl, "default-cluster");
        assertThat(result.size()).isEqualTo(1);
        assertThat(result.iterator().next()).isEqualTo("127.0.0.1:10911");
    }

    @Test
    public void testFetchMasterAddrByBrokerNameThrowsException() {
        assertThatThrownBy( () -> {
            CommandUtil.fetchMasterAddrByBrokerName(defaultMQAdminExtImpl, "default-cluster");
        })
                .isInstanceOf(Exception.class)
                .hasMessageContaining("No broker address for broker name");
    }

    @Test
    public void testFetchMasterAndSlaveAddrByBrokerName() throws InterruptedException, MQBrokerException, RemotingTimeoutException, RemotingSendRequestException, RemotingConnectException {
        Set<String> result = CommandUtil.fetchMasterAndSlaveAddrByBrokerName(defaultMQAdminExtImpl, "default-cluster");
        assertThat(result.size()).isEqualTo(0);
    }

    @Test
    public void testFetchBrokerNameByAddr() throws Exception {
        String result = CommandUtil.fetchBrokerNameByAddr(defaultMQAdminExtImpl, "127.0.0.1:10911");
        assertThat(result).isEqualTo("default-broker");
    }

    @Test
    public void testFetchBrokerNameByClusterName() throws Exception {
        Set<String> result = CommandUtil.fetchBrokerNameByClusterName(defaultMQAdminExtImpl, "default-cluster");
Original file line number	Diff line number	Diff line change
Expand Up		@@ -40,6 +40,7 @@
		import org.junit.Test;

		import static org.assertj.core.api.Assertions.assertThat;
		import static org.assertj.core.api.Assertions.assertThatThrownBy;
		import static org.mockito.ArgumentMatchers.anyLong;
		import static org.mockito.ArgumentMatchers.anyString;
		import static org.mockito.Mockito.mock;
Expand DownExpand Up		@@ -101,6 +102,34 @@ public void testFetchMasterAddrByClusterName() throws InterruptedException, MQBr
		assertThat(result.size()).isEqualTo(0);
		}

		@Test
		public void testFetchMasterAndSlaveAddrByClusterName() throws InterruptedException, MQBrokerException, RemotingTimeoutException, RemotingSendRequestException, RemotingConnectException {
		Set<String> result = CommandUtil.fetchMasterAndSlaveAddrByClusterName(defaultMQAdminExtImpl, "default-cluster");
		assertThat(result.size()).isEqualTo(1);
		assertThat(result.iterator().next()).isEqualTo("127.0.0.1:10911");
		}

		@Test
		public void testFetchMasterAddrByBrokerNameThrowsException() {
		assertThatThrownBy( () -> {
		CommandUtil.fetchMasterAddrByBrokerName(defaultMQAdminExtImpl, "default-cluster");
		})
		.isInstanceOf(Exception.class)
		.hasMessageContaining("No broker address for broker name");
		}

		@Test
		public void testFetchMasterAndSlaveAddrByBrokerName() throws InterruptedException, MQBrokerException, RemotingTimeoutException, RemotingSendRequestException, RemotingConnectException {
		Set<String> result = CommandUtil.fetchMasterAndSlaveAddrByBrokerName(defaultMQAdminExtImpl, "default-cluster");
		assertThat(result.size()).isEqualTo(0);
		}

		@Test
		public void testFetchBrokerNameByAddr() throws Exception {
		String result = CommandUtil.fetchBrokerNameByAddr(defaultMQAdminExtImpl, "127.0.0.1:10911");
		assertThat(result).isEqualTo("default-broker");
		}

		@Test
		public void testFetchBrokerNameByClusterName() throws Exception {
		Set<String> result = CommandUtil.fetchBrokerNameByClusterName(defaultMQAdminExtImpl, "default-cluster");
Expand Down