Author: rgodfrey
Date: Mon Jul 20 20:39:49 2009
New Revision: 796000
URL: http://svn.apache.org/viewvc?rev=796000&view=rev
Log:
Commented out some message modifying code in Diagnostic Exchange
Modified:
qpid/branches/java-broker-0-10/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
Modified:
qpid/branches/java-broker-0-10/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
URL:
http://svn.apache.org/viewvc/qpid/branches/java-broker-0-10/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java?rev=796000&r1=795999&r2=796000&view=diff
==============================================================================
---
qpid/branches/java-broker-0-10/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
(original)
+++
qpid/branches/java-broker-0-10/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
Mon Jul 20 20:39:49 2009
@@ -195,10 +195,11 @@
Long value = new Long(SizeOf.getUsedMemory());
AMQShortString key = new AMQShortString("memory");
-
- FieldTable headers =
((BasicContentHeaderProperties)payload.getMessageHeader().properties).getHeaders();
+
+ //TODO shouldn't modify messages... perhaps put a new message on the
queue?
+/* FieldTable headers =
((BasicContentHeaderProperties)payload.getMessageHeader().properties).getHeaders();
headers.put(key, value);
-
((BasicContentHeaderProperties)payload.getMessageHeader().properties).setHeaders(headers);
+
((BasicContentHeaderProperties)payload.getMessageHeader().properties).setHeaders(headers);*/
AMQQueue q = getQueueRegistry().getQueue(new
AMQShortString("diagnosticqueue"));
ArrayList<AMQQueue> queues = new ArrayList<AMQQueue>();
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
