From 4f7d0012ea2a394429312b9c2464822a2c9c8650 Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Fri, 5 Oct 2007 13:28:06 +0000
Subject: [PATCH] print out connection pool size.  record event time for new
 outgoing batch history status

---
 .../main/java/org/jumpmind/symmetric/job/AbstractJob.java    | 5 +----
 .../main/java/org/jumpmind/symmetric/job/HeartbeatJob.java   | 1 +
 symmetric/src/main/resources/symmetric-database.xml          | 2 +-
 symmetric/src/main/resources/symmetric-services.xml          | 4 ++--
 4 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/job/AbstractJob.java b/symmetric/src/main/java/org/jumpmind/symmetric/job/AbstractJob.java
index d0b94b966d..7820992c74 100644
--- a/symmetric/src/main/java/org/jumpmind/symmetric/job/AbstractJob.java
+++ b/symmetric/src/main/java/org/jumpmind/symmetric/job/AbstractJob.java
@@ -14,9 +14,7 @@ abstract public class AbstractJob extends TimerTask {
     @Override
     public void run() {
         try {
-            //printDatabaseStats();
             doJob();
-            //printDatabaseStats();
         } catch (Throwable ex) {
             getLogger().error(ex, ex);
         }
@@ -26,8 +24,7 @@ public void run() {
 
     abstract Log getLogger();
     
-    @SuppressWarnings("unused")
-    private void printDatabaseStats() {
+    protected void printDatabaseStats() {
         if (getLogger().isDebugEnabled() && dataSource instanceof BasicDataSource) {
             BasicDataSource ds = (BasicDataSource)dataSource;
             getLogger().debug("There are currently " + ds.getNumActive() + " active database connections.");
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/job/HeartbeatJob.java b/symmetric/src/main/java/org/jumpmind/symmetric/job/HeartbeatJob.java
index 450684b572..e1a36dbc40 100644
--- a/symmetric/src/main/java/org/jumpmind/symmetric/job/HeartbeatJob.java
+++ b/symmetric/src/main/java/org/jumpmind/symmetric/job/HeartbeatJob.java
@@ -12,6 +12,7 @@ public class HeartbeatJob extends AbstractJob {
 
     @Override
     public void doJob() throws Exception {
+        printDatabaseStats();
         bootstrapService.heartbeat();
     }
 
diff --git a/symmetric/src/main/resources/symmetric-database.xml b/symmetric/src/main/resources/symmetric-database.xml
index c86fed27d4..86595894dc 100644
--- a/symmetric/src/main/resources/symmetric-database.xml
+++ b/symmetric/src/main/resources/symmetric-database.xml
@@ -24,7 +24,7 @@
         <property name="maxWait" value="${db.pool.max.wait.millis}"/>
         <property name="minEvictableIdleTimeMillis" value="${db.pool.min.evictable.idle.millis}"/>
         <property name="timeBetweenEvictionRunsMillis" value="120000"/>
-         
+        <property name="numTestsPerEvictionRun" value="10"/>
     </bean>
 
     <bean id="jndiDataSource" class="org.springframework.jndi.JndiObjectFactoryBean"
diff --git a/symmetric/src/main/resources/symmetric-services.xml b/symmetric/src/main/resources/symmetric-services.xml
index 7ce101a9d5..e390c234f7 100644
--- a/symmetric/src/main/resources/symmetric-services.xml
+++ b/symmetric/src/main/resources/symmetric-services.xml
@@ -437,8 +437,8 @@
         <property name="runtimeConfiguration" ref="runtimeConfiguration" />
         <property name="createdSql">
             <value>
-                insert into ${sync.table.prefix}_outgoing_batch_hist (batch_id, status,
-                data_event_count) values (?, 'NE', ?)
+                insert into ${sync.table.prefix}_outgoing_batch_hist (batch_id, status, event_time
+                data_event_count) values (?, 'NE', current_timestamp, ?)
             </value>
         </property>
         <property name="errorSql">