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

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-12-03 05:20:31 -0500 (Thu, 03 Dec 2009)
New Revision: 8518

Modified:
   trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java
   trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
modified QueueImpl.toString() + failover failure info

Modified: trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java	2009-12-03 10:09:13 UTC (rev 8517)
+++ trunk/src/main/org/hornetq/core/server/impl/QueueImpl.java	2009-12-03 10:20:31 UTC (rev 8518)
@@ -867,7 +867,7 @@
    @Override
    public String toString()
    {
-      return "QueueImpl(name=" + name.toString() + ")";
+      return "QueueImpl[name=" + name.toString() + "]@" + Integer.toHexString(System.identityHashCode(this));
    }
 
    // Private

Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2009-12-03 10:09:13 UTC (rev 8517)
+++ trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2009-12-03 10:20:31 UTC (rev 8518)
@@ -265,8 +265,7 @@
       // System.out.println(threadDump(" - fired by ClusterTestBase::waitForBindings"));
 
       String msg = "Timed out waiting for bindings (bindingCount = " + bindingCount +
-                   ", totConsumers = " +
-                   totConsumers;
+                   ", totConsumers = " + totConsumers + ")";
 
       log.error(msg);
       
@@ -285,7 +284,7 @@
          {
             QueueBinding qBinding = (QueueBinding)binding;
             
-            System.out.println("Binding = " + qBinding + " with #consumers = " + qBinding.consumerCount()); 
+            System.out.println("Binding = " + qBinding + ", queue=" + qBinding.getQueue());
          }
       }
       System.out.println("=======================================================================");