Test a compile error on the build server. Do I get email?

symmetric/src/main/java/org/jumpmind/symmetric/service/IStatisticService.java

@@ -1,3 +1,22 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
 package org.jumpmind.symmetric.service;
 
 import java.util.Collection;

symmetric/src/main/java/org/jumpmind/symmetric/service/impl/BootstrapService.java

@@ -18,7 +18,6 @@
  * License along with this library; if not, see
  * <http://www.gnu.org/licenses/>.
  */
-
 package org.jumpmind.symmetric.service.impl;
 
 import java.net.ConnectException;

symmetric/src/main/java/org/jumpmind/symmetric/service/impl/StatisticService.java

@@ -1,3 +1,22 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
 package org.jumpmind.symmetric.service.impl;
 
 import java.util.Collection;

symmetric/src/main/java/org/jumpmind/symmetric/service/jmx/IncomingManagementService.java

@@ -0,0 +1,39 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
+package org.jumpmind.symmetric.service.jmx;
+
+import java.math.BigDecimal;
+
+import org.jumpmind.symmetric.statistic.IStatisticManager;
+import org.springframework.jmx.export.annotation.ManagedResource;
+
+@ManagedResource(description = "The management interface for incoming synchronization")
+public class IncomingManagementService {
+
+    IStatisticManager statisticManager;
+
+    public void setStatisticManager(IStatisticManager statisticManager) {
+        this.statisticManager = statisticManager;
+    }
+
+    public BigDecimal getDatabaseMsPerRow() {
+
+    }
+}

symmetric/src/main/java/org/jumpmind/symmetric/service/jmx/NodeManagementService.java

@@ -0,0 +1,27 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
+package org.jumpmind.symmetric.service.jmx;
+
+import org.springframework.jmx.export.annotation.ManagedResource;
+
+@ManagedResource(description = "The management interface for nodes")
+public class NodeManagementService {
+
+}

symmetric/src/main/java/org/jumpmind/symmetric/service/jmx/OutgoingManagementService.java

@@ -0,0 +1,27 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
+package org.jumpmind.symmetric.service.jmx;
+
+import org.springframework.jmx.export.annotation.ManagedResource;
+
+@ManagedResource(description = "The management interface for outgoing synchronization")
+public class OutgoingManagementService {
+
+}

symmetric/src/main/java/org/jumpmind/symmetric/service/jmx/SymmetricManagementService.java

@@ -18,7 +18,6 @@
  * License along with this library; if not, see
  * <http://www.gnu.org/licenses/>.
  */
-
 package org.jumpmind.symmetric.service.jmx;
 
 import java.io.ByteArrayOutputStream;
@@ -46,7 +45,7 @@
 import org.springframework.jmx.export.annotation.ManagedOperationParameters;
 import org.springframework.jmx.export.annotation.ManagedResource;
 
-@ManagedResource(description = "The management interface for symmetric")
+@ManagedResource(description = "The management interface for SymmetricDS")
 public class SymmetricManagementService {
 
     private IRuntimeConfig runtimeConfiguration;

symmetric/src/main/java/org/jumpmind/symmetric/statistic/IStatisticManager.java

@@ -1,3 +1,22 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
 package org.jumpmind.symmetric.statistic;
 
 public interface IStatisticManager {

symmetric/src/main/java/org/jumpmind/symmetric/statistic/Statistic.java

@@ -1,3 +1,22 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
 package org.jumpmind.symmetric.statistic;
 
 import java.math.BigDecimal;

symmetric/src/main/java/org/jumpmind/symmetric/statistic/StatisticManager.java

@@ -1,3 +1,22 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
 package org.jumpmind.symmetric.statistic;
 
 import java.util.Date;
@@ -15,24 +34,26 @@ public class StatisticManager implements IStatisticManager {
     INodeService nodeService;
 
     IStatisticService statisticService;
-    
+
     synchronized public void init() {
-        refresh(new Date());
-    }    
-
+        if (statistics == null) {
+            refresh(new Date());
+        }
+    }
+
     synchronized public void flush() {
         Date captureEndTime = new Date();
         if (statistics != null) {
             statisticService.save(statistics.values(), captureEndTime);
         }
         refresh(captureEndTime);
     }
-    
+
     synchronized protected void refresh(Date lastCaptureEndTime) {
         if (statistics == null) {
             statistics = new HashMap<StatisticName, Statistic>();
         }
-        
+
         statistics.clear();
 
         Node node = nodeService.findIdentity();
@@ -48,6 +69,7 @@ synchronized protected void refresh(Date lastCaptureEndTime) {
     }
 
     public Statistic getStatistic(StatisticName name) {
+        this.init();
         return statistics.get(name);
     }
 

symmetric/src/main/java/org/jumpmind/symmetric/statistic/StatisticName.java

@@ -1,3 +1,22 @@
+/*
+ * SymmetricDS is an open source database synchronization solution.
+ *   
+ * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see
+ * <http://www.gnu.org/licenses/>.
+ */
 package org.jumpmind.symmetric.statistic;
 
 public enum StatisticName {

symmetric/src/main/resources/symmetric-jmx.xml

@@ -23,6 +23,9 @@
         <property name="mappings">
             <props>
                 <prop key="managementService">Symmetric:name=${symmetric.runtime.engine.name}</prop>
+                <prop key="incomingManagementService">org.jumpmind.symmetric.${symmetric.runtime.engine.name}:name=Incoming</prop>
+                <prop key="outgoingManagementService">org.jumpmind.symmetric.${symmetric.runtime.engine.name}:name=Outgoing</prop>
+                <prop key="nodeManagementService">org.jumpmind.symmetric.${symmetric.runtime.engine.name}:name=Node</prop>                
             </props>
         </property>
         <property name="mappingLocations">
@@ -44,5 +47,9 @@
         <property name="nodeService" ref="nodeService" />
         <property name="dataExtractorService" ref="dataExtractorService" />
     </bean>
+
+    <bean id="incomingManagementService" class="org.jumpmind.symmetric.service.jmx.IncomingManagementService"/>
+    <bean id="outgoingManagementService" class="org.jumpmind.symmetric.service.jmx.OutgoingManagementService"/>
+    <bean id="nodeManagementService" class="org.jumpmind.symmetric.service.jmx.NodeManagementService"/>
 
 </beans>

symmetric/src/main/resources/symmetric-services.xml

@@ -13,11 +13,10 @@
         <property name="runtimeConfiguration" ref="runtimeConfiguration" />        
     </bean>
 
-    <bean id="statisticManager" class="org.jumpmind.symmetric.statistic.StatisticManager" init-method="init">
+    <bean id="statisticManager" class="org.jumpmind.symmetric.statistic.StatisticManager">
         <property name="statisticService" ref="statisticService"/>
         <property name="nodeService" ref="nodeService"/>
-    </bean>
-
+    </bean>    
 
     <bean id="transportManager" class="org.jumpmind.symmetric.transport.TransportManagerFactoryBean"
         scope="singleton">