Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add some more diagnostic logging to test

This commit is contained in:
gtully 2015-01-09 11:51:16 +00:00
parent 7948d69056
commit 383c27e245
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-unit-tests/src/test/java/org/apache/activemq/network/NetworkBrokerDetachTest.java
View File

@ -19,6 +19,7 @@ package org.apache.activemq.network;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
import java.io.File; import java.io.File;
import java.util.Arrays;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
@ -267,6 +268,7 @@ public class NetworkBrokerDetachTest {
if (view.getName().equals(destination.getPhysicalName())) { if (view.getName().equals(destination.getPhysicalName())) {
LOG.info("Consumers for " + destination.getPhysicalName() + " on " + broker + " : " + view.getConsumerCount()); LOG.info("Consumers for " + destination.getPhysicalName() + " on " + broker + " : " + view.getConsumerCount());
LOG.info("Subs: " + Arrays.asList(view.getSubscriptions()));
if (expectedCount == view.getConsumerCount()) { if (expectedCount == view.getConsumerCount()) {
result = true; result = true;
} }
@ -290,7 +292,7 @@ public class NetworkBrokerDetachTest {
if (view != null) { if (view != null) {
ObjectName[] subs = broker.getAdminView().getInactiveDurableTopicSubscribers(); ObjectName[] subs = broker.getAdminView().getInactiveDurableTopicSubscribers();
if (subs != null) { if (subs != null) {
LOG.info("inactive durable subs on " + broker + " : " + subs); LOG.info("inactive durable subs on " + broker + " : " + Arrays.asList(subs));
if (expectedCount == subs.length) { if (expectedCount == subs.length) {
result = true; result = true;
} }