Skip to content

Commit 771aa64

Browse files
committed
Log more information in test
1 parent c9079db commit 771aa64

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/test/java/com/rabbitmq/client/amqp/impl/RecoveryClusterTest.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -258,12 +258,14 @@ void clusterRestart() {
258258
try {
259259
Management.QueueInfo queueInfo = management.queueInfo(q);
260260
System.out.printf(
261-
"Queue '%s': leader '%s', followers '%s'%n",
261+
"Queue '%s': leader '%s', followers '%s', consumer(s) %d, message(s) %d%n",
262262
q,
263263
queueInfo.leader(),
264264
queueInfo.members().stream()
265265
.filter(n -> !n.equals(queueInfo.leader()))
266-
.collect(toList()));
266+
.collect(toList()),
267+
queueInfo.consumerCount(),
268+
queueInfo.messageCount());
267269
} catch (Exception ex) {
268270
LOGGER.info(
269271
"Error while retrieving queue information for '{}': {}", q, ex.getMessage());

0 commit comments

Comments
 (0)