Author: ritchiem
Date: Fri Mar 13 13:59:25 2009
New Revision: 753253
URL: http://svn.apache.org/viewvc?rev=753253&view=rev
Log:
QPID-1730 : Logging update highlighted that we were printing the queue before
we had fully initialised it.
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQPriorityQueue.java
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/PriorityQueueEntryList.java
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQPriorityQueue.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQPriorityQueue.java?rev=753253&r1=753252&r2=753253&view=diff
==============================================================================
---
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQPriorityQueue.java
(original)
+++
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQPriorityQueue.java
Fri Mar 13 13:59:25 2009
@@ -71,7 +71,7 @@
@Override
public String getType()
{
- return getClass().getName() + "[" + getName() + "][Priorities:" +
getPriorities() + "]";
+ return getClass().getSimpleName() + "[" + getName() + "][Priorities:"
+ getPriorities() + "]";
}
}
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/PriorityQueueEntryList.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/PriorityQueueEntryList.java?rev=753253&r1=753252&r2=753253&view=diff
==============================================================================
---
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/PriorityQueueEntryList.java
(original)
+++
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/PriorityQueueEntryList.java
Fri Mar 13 13:59:25 2009
@@ -237,7 +237,7 @@
for (int index = 0; index < _priorities; index++)
{
QueueEntryList queueEntryList = _priorityLists[index];
- _log.debug("Queue (" + _queue + ":" + _queue.getName() + ")["
+ index + "] usage:" + queueEntryList.memoryUsed()
+ _log.debug("Queue (" + _queue.getName() + ")[" + index + "]
usage:" + queueEntryList.memoryUsed()
+ "/" + queueEntryList.getMemoryUsageMaximum()
+ "/" + queueEntryList.dataSize());
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
