Author: clebert.suconic(a)jboss.com
Date: 2009-11-30 21:55:31 -0500 (Mon, 30 Nov 2009)
New Revision: 8473
Modified:
trunk/src/main/org/hornetq/core/server/cluster/impl/RemoteQueueBindingImpl.java
trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
Adding log information for debug
Modified: trunk/src/main/org/hornetq/core/server/cluster/impl/RemoteQueueBindingImpl.java
===================================================================
---
trunk/src/main/org/hornetq/core/server/cluster/impl/RemoteQueueBindingImpl.java 2009-11-30
19:37:26 UTC (rev 8472)
+++
trunk/src/main/org/hornetq/core/server/cluster/impl/RemoteQueueBindingImpl.java 2009-12-01
02:55:31 UTC (rev 8473)
@@ -262,5 +262,33 @@
{
return consumerCount;
}
+
+ @Override
+ public String toString()
+ {
+ return "RemoteQueueBindingImpl [address=" + address +
+ ", consumerCount=" +
+ consumerCount +
+ ", distance=" +
+ distance +
+ ", filters=" +
+ filters +
+ ", id=" +
+ id +
+ ", idsHeaderName=" +
+ idsHeaderName +
+ ", queueFilter=" +
+ queueFilter +
+ ", remoteQueueID=" +
+ remoteQueueID +
+ ", routingName=" +
+ routingName +
+ ", storeAndForwardQueue=" +
+ storeAndForwardQueue +
+ ", uniqueName=" +
+ uniqueName +
+ "]";
+ }
+
}
Modified:
trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-11-30
19:37:26 UTC (rev 8472)
+++
trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-12-01
02:55:31 UTC (rev 8473)
@@ -270,9 +270,26 @@
log.error(msg);
- // Sending thread dump.. trying to get some information about the server case the
binding didn't arrive
+ // Sending thread dump into junit report.. trying to get some information about
the server case the binding didn't arrive
System.out.println(threadDump(msg));
+
+
+ Bindings bindings = po.getBindingsForAddress(new SimpleString(address));
+
System.out.println("=======================================================================");
+ System.out.println("Binding information for address = " + address +
" on node " + node);
+
+ for (Binding binding : bindings.getBindings())
+ {
+ if ((binding instanceof LocalQueueBinding && local) || (binding
instanceof RemoteQueueBinding && !local))
+ {
+ QueueBinding qBinding = (QueueBinding)binding;
+
+ System.out.println("Binding = " + qBinding + " with #consumers
= " + qBinding.consumerCount());
+ }
+ }
+
System.out.println("=======================================================================");
+
throw new IllegalStateException(msg);
}
Show replies by date