Added batching stats

JumpMind · May 10, 2008 · 518de49 · 518de49
1 parent 668dfb3
commit 518de49
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 1 deletion.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java
@@ -44,6 +44,8 @@
 import org.jumpmind.symmetric.model.OutgoingBatch.Status;
 import org.jumpmind.symmetric.service.INodeService;
 import org.jumpmind.symmetric.service.IOutgoingBatchService;
+import org.jumpmind.symmetric.statistic.IStatisticManager;
+import org.jumpmind.symmetric.statistic.StatisticName;
 import org.jumpmind.symmetric.util.MaxRowsStatementCreator;
 import org.springframework.dao.DataAccessException;
 import org.springframework.jdbc.core.ConnectionCallback;
@@ -59,6 +61,8 @@ public class OutgoingBatchService extends AbstractService implements IOutgoingBa
     private INodeService nodeService;
 
     private IDbDialect dbDialect;
+
+    private IStatisticManager statisticManager;
 
     /**
      * Create a batch and mark events as tied to that batch. We iterate through all the events so we can find
@@ -179,6 +183,8 @@ public Object doInConnection(Connection conn) throws SQLException, DataAccessExc
                                 history.setDataEventCount(dataEventCount);
                                 history.setDatabaseMillis(databaseMillis);
                                 insertOutgoingBatchHistory(history);
+                                statisticManager.getStatistic(StatisticName.OUTGOING_MS_PER_EVENT_BATCHED).add(databaseMillis, dataEventCount);
+                                statisticManager.getStatistic(StatisticName.OUTGOING_EVENTS_PER_BATCH).add(dataEventCount, 1);
 
                             }
 
@@ -330,4 +336,8 @@ public void setNodeService(INodeService nodeService) {
         this.nodeService = nodeService;
     }
 
+    public void setStatisticManager(IStatisticManager statisticManager) {
+        this.statisticManager = statisticManager;
+    }
+
 }
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/statistic/StatisticName.java b/symmetric/src/main/java/org/jumpmind/symmetric/statistic/StatisticName.java
@@ -30,6 +30,9 @@ public enum StatisticName {
     INCOMING_BATCH_COUNT,
     INCOMING_SKIP_BATCH_COUNT,
 
+    OUTGOING_MS_PER_EVENT_BATCHED,
+    OUTGOING_EVENTS_PER_BATCH,
+
     OUTGOING_NETWORK_ERRORS,
     OUTGOING_DATABASE_ERRORS,
     OUTGOING_ROWS_PER_MS,

diff --git a/symmetric/src/main/resources/symmetric-services.xml b/symmetric/src/main/resources/symmetric-services.xml
@@ -92,7 +92,8 @@
         <property name="jdbcTemplate" ref="jdbcTemplate" />
         <property name="runtimeConfiguration" ref="runtimeConfiguration" />
         <property name="parameterService" ref="parameterService" />
-        <property name="nodeService" ref="nodeService" />
+        <property name="nodeService" ref="nodeService" />
+        <property name="statisticManager" ref="statisticManager" />        
         <property name="dbDialect" ref="dbDialect" />
     </bean>