activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1130974 - in /activemq/trunk: activemq-core/src/main/java/org/apache/activemq/broker/jmx/ activemq-web-console/src/main/webapp/
Date Fri, 03 Jun 2011 10:08:22 GMT
Author: gtully
Date: Fri Jun  3 10:08:22 2011
New Revision: 1130974

URL: http://svn.apache.org/viewvc?rev=1130974&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3356 - DispatchedQueueCount (messages pending dispatch)
should be visible on the jmx connection view

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
    activemq/trunk/activemq-web-console/src/main/webapp/connection.jsp

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java?rev=1130974&r1=1130973&r2=1130974&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
Fri Jun  3 10:08:22 2011
@@ -62,6 +62,10 @@ public class ConnectionView implements C
         return connection.isActive();
     }
 
+    public int getDispatchQueueSize() {
+        return connection.getDispatchQueueSize();
+    }
+
     /**
      * Resets the statistics
      */

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java?rev=1130974&r1=1130973&r2=1130974&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
Fri Jun  3 10:08:22 2011
@@ -52,9 +52,16 @@ public interface ConnectionViewMBean ext
     /**
      * Returns the source address for this connection
      * 
-     * @return the souce address for this connection
+     * @return the source address for this connection
      */
     @MBeanInfo("Source address for this connection")
     String getRemoteAddress();
 
+    /**
+     * Returns the number of messages to be dispatched to this connection
+     * @return the  number of messages pending dispatch
+     */
+    @MBeanInfo("The number of messages pending dispatch")
+    public int getDispatchQueueSize();
+
 }

Modified: activemq/trunk/activemq-web-console/src/main/webapp/connection.jsp
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-web-console/src/main/webapp/connection.jsp?rev=1130974&r1=1130973&r2=1130974&view=diff
==============================================================================
--- activemq/trunk/activemq-web-console/src/main/webapp/connection.jsp (original)
+++ activemq/trunk/activemq-web-console/src/main/webapp/connection.jsp Fri Jun  3 10:08:22
2011
@@ -61,6 +61,10 @@ No connection could be found for ID <c:o
 			<td class="label">Slow</td>
 			<td><c:out value="${row.slow}" /></td>
 		</tr>
+		<tr>
+			<td class="label">Dispatch Queue Size</td>
+		    <td><c:out value="${row.dispatchQueueSize}" /></td>
+		</tr>
 	</tbody>
 </table>
 



Mime
View raw message