[hornetq-commits] JBoss hornetq SVN: r8473 - in trunk: tests/src/org/hornetq/tests/integration/cluster/distribution and 1 other directory.

[do-not-reply at jboss.org]

Author: clebert.suconic at 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);
    }