activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1145726 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
Date Tue, 12 Jul 2011 19:10:55 GMT
Author: tabish
Date: Tue Jul 12 19:10:55 2011
New Revision: 1145726

URL: http://svn.apache.org/viewvc?rev=1145726&view=rev
Log:
Fix for: https://issues.apache.org/jira/browse/AMQ-3023

browseMessages should return the message not the CompositeData instance that's returned by
the browse method.


Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java?rev=1145726&r1=1145725&r2=1145726&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
Tue Jul 12 19:10:55 2011
@@ -128,7 +128,7 @@ public class DestinationView implements 
     public long getMinEnqueueTime() {
         return destination.getDestinationStatistics().getProcessTime().getMinTime();
     }
-    
+
     public boolean isPrioritizedMessages() {
         return destination.isPrioritizedMessages();
     }
@@ -199,7 +199,7 @@ public class DestinationView implements 
             try {
                 Message message = messages[i];
                 if (selectorExpression == null) {
-                    answer.add(OpenTypeSupport.convert(message));
+                    answer.add(message);
                 } else {
                     ctx.setMessageReference(message);
                     if (selectorExpression.matches(ctx)) {
@@ -339,20 +339,20 @@ public class DestinationView implements 
     public void setProducerFlowControl(boolean producerFlowControl) {
         destination.setProducerFlowControl(producerFlowControl);
     }
-    
+
     public boolean isAlwaysRetroactive() {
-    	return destination.isAlwaysRetroactive();
+        return destination.isAlwaysRetroactive();
     }
-    
+
     public void setAlwaysRetroactive(boolean alwaysRetroactive) {
-    	destination.setAlwaysRetroactive(alwaysRetroactive);
+        destination.setAlwaysRetroactive(alwaysRetroactive);
     }
 
     /**
      * Set's the interval at which warnings about producers being blocked by
      * resource usage will be triggered. Values of 0 or less will disable
      * warnings
-     * 
+     *
      * @param blockedProducerWarningInterval the interval at which warning about
      *            blocked producers will be triggered.
      */
@@ -361,7 +361,7 @@ public class DestinationView implements 
     }
 
     /**
-     * 
+     *
      * @return the interval at which warning about blocked producers will be
      *         triggered.
      */



Mime
View raw message