This is an automated email from the ASF dual-hosted git repository.
lizhimins pushed a commit to branch rocketmq-studio
in repository https://gitbox.apache.org/repos/asf/rocketmq-dashboard.git
The following commit(s) were added to refs/heads/rocketmq-studio by this push:
new a3b0444e4 [ISSUE #2915] fix(broker): preserve diff failure details
(#2920)
a3b0444e4 is described below
commit a3b0444e4ef8d63a10acfd135ed502d1ed8f5b58
Author: shown <[email protected]>
AuthorDate: Fri Sep 4 15:24:39 2026 +0800
[ISSUE #2915] fix(broker): preserve diff failure details (#2920)
---
.../apache/rocketmq/studio/cluster/broker/BrokerConfigDiffService.java | 1 +
.../rocketmq/studio/cluster/broker/BrokerConfigDiffServiceTest.java | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git
a/server/src/main/java/org/apache/rocketmq/studio/cluster/broker/BrokerConfigDiffService.java
b/server/src/main/java/org/apache/rocketmq/studio/cluster/broker/BrokerConfigDiffService.java
index 4096708af..771d37e56 100644
---
a/server/src/main/java/org/apache/rocketmq/studio/cluster/broker/BrokerConfigDiffService.java
+++
b/server/src/main/java/org/apache/rocketmq/studio/cluster/broker/BrokerConfigDiffService.java
@@ -76,6 +76,7 @@ public class BrokerConfigDiffService {
.name(broker.name())
.address(broker.address())
.reachable(false)
+ .message(exception.getMessage())
.build());
}
}
diff --git
a/server/src/test/java/org/apache/rocketmq/studio/cluster/broker/BrokerConfigDiffServiceTest.java
b/server/src/test/java/org/apache/rocketmq/studio/cluster/broker/BrokerConfigDiffServiceTest.java
index 165f57e07..a99f78f52 100644
---
a/server/src/test/java/org/apache/rocketmq/studio/cluster/broker/BrokerConfigDiffServiceTest.java
+++
b/server/src/test/java/org/apache/rocketmq/studio/cluster/broker/BrokerConfigDiffServiceTest.java
@@ -143,7 +143,7 @@ class BrokerConfigDiffServiceTest {
BrokerConfigDiffVO.BrokerStatusVO::getMessage)
.containsExactly(
tuple("10.0.0.1:10911", true, null),
- tuple("10.0.0.2:10911", false, null));
+ tuple("10.0.0.2:10911", false, "broker unavailable"));
}
@Test