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("=======================================================================");
Show replies by date