svn commit: r1088715 - in /activemq/activemq-apollo/trunk/apollo-bdb/src/main: scala/org/apache/activemq/apollo/broker/store/bdb/ scala/org/apache/activemq/apollo/broker/store/bdb/dto/ webapp/WEB-INF/org/apache/activemq/apollo/broker/store/bdb/dto/

[chirino]

Author: chirino
Date: Mon Apr  4 18:49:54 2011
New Revision: 1088715

URL: http://svn.apache.org/viewvc?rev=1088715&view=rev
Log:
Display more DBD store stats: # of pending stores.

Modified:
    
activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/BDBStore.scala
    
activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.java
    
activemq/activemq-apollo/trunk/apollo-bdb/src/main/webapp/WEB-INF/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.jade

Modified: 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/BDBStore.scala
URL: 
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/BDBStore.scala?rev=1088715&r1=1088714&r2=1088715&view=diff
==============================================================================
--- 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/BDBStore.scala
 (original)
+++ 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/BDBStore.scala
 Mon Apr  4 18:49:54 2011
@@ -255,6 +255,8 @@ class BDBStore(var config:BDBStoreDTO) e
     rc.flushed_message_counter = metric_flushed_message_counter
     rc.flushed_enqueue_counter = metric_flushed_enqueue_counter
 
+    rc.pending_stores = pendingStores.size
+
     callback(rc)
   }
 

Modified: 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.java
URL: 
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.java?rev=1088715&r1=1088714&r2=1088715&view=diff
==============================================================================
--- 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.java
 (original)
+++ 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/scala/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.java
 Mon Apr  4 18:49:54 2011
@@ -41,4 +41,6 @@ public class BDBStoreStatusDTO extends S
     @XmlElement(name="message_load_batch_size")
     public IntMetricDTO message_load_batch_size;
 
+    @XmlElement(name="pending_stores")
+    public int pending_stores;
 }

Modified: 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/webapp/WEB-INF/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.jade
URL: 
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-bdb/src/main/webapp/WEB-INF/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.jade?rev=1088715&r1=1088714&r2=1088715&view=diff
==============================================================================
--- 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/webapp/WEB-INF/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.jade
 (original)
+++ 
activemq/activemq-apollo/trunk/apollo-bdb/src/main/webapp/WEB-INF/org/apache/activemq/apollo/broker/store/bdb/dto/BDBStoreStatusDTO.jade
 Mon Apr  4 18:49:54 2011
@@ -24,6 +24,8 @@
 
 p state: #{state} for #{ uptime(state_since) }
 
+p pending stores: #{pending_stores}
+
 h2 Cancel Stats
 p canceled message stores: #{canceled_message_counter}
 p canceled message enqueues: #{canceled_enqueue_counter}