Check in the pattern for new tests for review.

symmetric/symmetric-client/src/test/java/org/jumpmind/symmetric/service/impl/JdbcDataLoaderServiceTest.java

@@ -0,0 +1,6 @@
+package org.jumpmind.symmetric.service.impl;
+
+
+public class JdbcDataLoaderServiceTest extends AbstractDataLoaderServiceTest {
+
+}

symmetric/symmetric-client/src/test/java/org/jumpmind/symmetric/test/TestSetupUtil.java

@@ -0,0 +1,14 @@
+package org.jumpmind.symmetric.test;
+
+import org.jumpmind.symmetric.ISymmetricEngine;
+
+public class TestSetupUtil {
+
+    static private ISymmetricEngine engine;
+
+    public static ISymmetricEngine prepareForServiceTests() {
+        // TODO
+        return engine;
+    }
+
+}

symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java

@@ -594,6 +594,10 @@ public String getTablePrefix() {
     public ITransportManager getTransportManager() {
         return transportManager;
     }
+
+    public IExtensionPointManager getExtensionPointManager() {
+        return extensionPointManger;
+    }
 
     private void removeMeFromMap(Map<String, ISymmetricEngine> map) {
         Set<String> keys = new HashSet<String>(map.keySet());

symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/ISymmetricEngine.java

@@ -24,6 +24,7 @@
 import org.jumpmind.log.Log;
 import org.jumpmind.symmetric.common.DeploymentType;
 import org.jumpmind.symmetric.db.ISymmetricDialect;
+import org.jumpmind.symmetric.ext.IExtensionPointManager;
 import org.jumpmind.symmetric.job.IJobManager;
 import org.jumpmind.symmetric.job.OutgoingPurgeJob;
 import org.jumpmind.symmetric.job.PullJob;
@@ -252,5 +253,7 @@ public interface ISymmetricEngine {
     public String getTablePrefix();
 
     public Log getLog();
-
+
+    public IExtensionPointManager getExtensionPointManager();
+
 }

symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/ext/ExtensionPointManager.java

@@ -64,6 +64,8 @@ public class ExtensionPointManager implements IExtensionPointManager {
 
     private ISymmetricEngine engine;
 
+    private Map<String, IExtensionPoint> extensions;
+
     private List<ExtensionPointMetaData> extensionPoints = new ArrayList<ExtensionPointMetaData>();
 
     public ExtensionPointManager(Log log, ISymmetricEngine engine) {
@@ -76,7 +78,7 @@ public void register() throws BeansException {
         ApplicationContext cfgBeanFactory = new ClassPathXmlApplicationContext(
                 "classpath://symmetric-extensions.xml");
         if (!initialized) {
-            Map<String, IExtensionPoint> extensions = new TreeMap<String, IExtensionPoint>();
+            extensions = new TreeMap<String, IExtensionPoint>();
             extensions.putAll(cfgBeanFactory.getBeansOfType(IExtensionPoint.class));
             if (cfgBeanFactory.getParentBeanFactory() != null
                     && cfgBeanFactory.getParentBeanFactory() instanceof ListableBeanFactory) {
@@ -245,4 +247,13 @@ protected boolean registerExtension(String beanName, IExtensionPoint ext) {
         return installed;
     }
 
+    @SuppressWarnings("unchecked")
+    public <T extends IExtensionPoint> T getExtensionPoint(String name) {
+        if (extensions != null) {
+            return (T)extensions.get(name);
+        } else {
+            return null;
+        }
+    }
+
 }

symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/ext/IExtensionPointManager.java

@@ -22,6 +22,7 @@
 
 import java.util.List;
 
+import org.jumpmind.extension.IExtensionPoint;
 import org.springframework.beans.BeansException;
 
 /**
@@ -34,4 +35,6 @@ public interface IExtensionPointManager {
 
     public List<ExtensionPointMetaData> getExtensionPoints();
 
+    public <T extends IExtensionPoint> T getExtensionPoint(String name);
+
 }

symmetric/symmetric-core/src/test/java/org/jumpmind/symmetric/TestConstants.java

@@ -0,0 +1,26 @@
+package org.jumpmind.symmetric;
+
+import org.jumpmind.symmetric.model.Node;
+
+public class TestConstants {
+
+    public final static String TEST_CLIENT_EXTERNAL_ID = "00001";
+    public static final String TEST_CLIENT_NODE_GROUP = "test-node-group";
+    public static final String TEST_CLIENT_NODE_GROUP_2 = "test-node-group2";
+    public final static Node TEST_CLIENT_NODE = new Node(TestConstants.TEST_CLIENT_EXTERNAL_ID, TestConstants.TEST_CLIENT_NODE_GROUP);
+
+    public final static String TEST_ROOT_EXTERNAL_ID = "00000";
+    public static final String TEST_ROOT_NODE_GROUP = "test-root-group";
+    public final static Node TEST_ROOT_NODE = new Node(TestConstants.TEST_ROOT_EXTERNAL_ID, TestConstants.TEST_ROOT_NODE_GROUP);
+
+    public static final String TEST_DROP_ALL_SCRIPT = "/test-data-drop-all.sql";
+    public static final String TEST_DROP_SEQ_SCRIPT = "/test-data-drop-";
+    public static final String TEST_ROOT_DOMAIN_SETUP_SCRIPT = "-integration-root-setup.sql";
+    public static final String TEST_CONTINUOUS_SETUP_SCRIPT = "-database-setup.sql";
+    public static final String TEST_CONTINUOUS_NODE_GROUP = TEST_ROOT_NODE_GROUP;
+    public static final String TEST_CHANNEL_ID = "testchannel";
+    public static final String TEST_CHANNEL_ID_OTHER = "other";
+    public static final int TEST_TRIGGER_HISTORY_ID = 1;
+
+    public static final String MYSQL = "mysql";
+}

symmetric/symmetric-server/src/test/java/org/jumpmind/symmetric/ext/TestDataWriterFilter.java → symmetric/symmetric-core/src/test/java/org/jumpmind/symmetric/ext/TestDataWriterFilter.java

@@ -29,9 +29,6 @@
 import org.jumpmind.symmetric.io.data.writer.DatabaseWriterFilterAdapter;
 import org.jumpmind.symmetric.io.data.writer.IDatabaseWriterFilter;
 
-/**
- * 
- */
 public class TestDataWriterFilter extends DatabaseWriterFilterAdapter implements
         IDatabaseWriterFilter {