From commits-return-15878-apmail-activemq-commits-archive=activemq.apache.org@activemq.apache.org Mon Apr 04 18:50:16 2011 Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 52401 invoked from network); 4 Apr 2011 18:50:16 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 4 Apr 2011 18:50:16 -0000 Received: (qmail 66744 invoked by uid 500); 4 Apr 2011 18:50:16 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 66711 invoked by uid 500); 4 Apr 2011 18:50:15 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 66704 invoked by uid 99); 4 Apr 2011 18:50:15 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 04 Apr 2011 18:50:15 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 04 Apr 2011 18:50:14 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 7CF1C23888CB; Mon, 4 Apr 2011 18:49:54 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: 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/ Date: Mon, 04 Apr 2011 18:49:54 -0000 To: commits@activemq.apache.org From: chirino@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20110404184954.7CF1C23888CB@eris.apache.org> 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}