fixes #155 replace RuleLoaderStartupHook with MultiThreadRuleExecutor

Author: stevehu

pom.xml

@@ -46,14 +46,16 @@
         </snapshotRepository>
     </distributionManagement>
 
-            <repositories>
+    <repositories>
         <repository>
-            <id>confluent</id>
-            <url>https://packages.confluent.io/maven/</url>
-        </repository>
-        <repository>
-            <id>jitpack.io</id>
-            <url>https://jitpack.io</url>
+            <id>snapshot</id>
+            <url>https://central.sonatype.com/repository/maven-snapshots/</url>
+            <releases>
+                <enabled>false</enabled>
+            </releases>
+            <snapshots>
+                <enabled>true</enabled>
+            </snapshots>
         </repository>
         <repository>
             <id>central</id>
@@ -62,13 +64,6 @@
                 <enabled>true</enabled>
             </releases>
         </repository>
-        <repository>
-            <id>snapshot</id>
-            <url>https://central.sonatype.org/content/repositories/snapshots</url>
-            <snapshots>
-                <enabled>true</enabled>
-            </snapshots>
-        </repository>
     </repositories>
     <pluginRepositories>
         <pluginRepository>
@@ -300,7 +295,12 @@
         </dependency>
         <dependency>
             <groupId>com.networknt</groupId>
-            <artifactId>ruleloader-config</artifactId>
+            <artifactId>rule-config</artifactId>
+            <version>${version.light-4j}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.networknt</groupId>
+            <artifactId>rule-loader</artifactId>
             <version>${version.light-4j}</version>
         </dependency>
         <dependency>

src/main/java/com/networknt/aws/lambda/handler/middleware/transformer/AbstractTransformerMiddleware.java

@@ -3,6 +3,7 @@
 import com.networknt.aws.lambda.handler.MiddlewareHandler;
 import com.networknt.config.Config;
 import com.networknt.rule.*;
+import com.networknt.service.SingletonServiceFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -11,58 +12,11 @@
 
 public abstract class AbstractTransformerMiddleware implements MiddlewareHandler {
     private static final Logger LOG = LoggerFactory.getLogger(AbstractTransformerMiddleware.class);
-    static Map<String, Object> endpointRulesMap = new HashMap<>();
-    public static Map<String, Rule> rules;
-    public static RuleEngine ruleEngine;
 
     public AbstractTransformerMiddleware() {
-
-        // load endpointRules
-        RuleLoaderConfig ruleLoaderConfig = RuleLoaderConfig.load();
-        if (ruleLoaderConfig.isEnabled()) {
-            if (RuleLoaderConfig.RULE_SOURCE_CONFIG_FOLDER.equals(ruleLoaderConfig.getRuleSource())) {
-                // load the rules for the service from the externalized config folder. The filename is rules.yml
-                String ruleString = Config.getInstance().getStringFromFile("rules.yml");
-                rules = RuleMapper.string2RuleMap(ruleString);
-                LOG.info("Load YAML rules from config folder with size = {}", rules.size());
-                // load the endpoint rule mapping from the rule-loader.yml
-                endpointRulesMap = ruleLoaderConfig.getEndpointRules();
-            }
-            if (rules != null) {
-                // create the rule engine with the rule map.
-                ruleEngine = new RuleEngine(rules, null);
-                // iterate all action classes to initialize them to ensure that the jar file are deployed and configuration is registered.
-                // This is to prevent runtime exception and also ensure that the configuration is part of the server info response.
-                loadPluginClass();
-            }
-        } else {
-            LOG.error("RuleLoaderConfig is not enabled. Please check the configuration.");
-        }
         LOG.info("AbstractTransformerMiddleware is constructed");
     }
 
-    public static void loadPluginClass() {
-        // iterate the rules map to find the action classes.
-        for (Rule rule : rules.values()) {
-            for (RuleAction action : rule.getActions()) {
-                String actionClass = action.getActionClassName();
-                loadActionClass(actionClass);
-            }
-        }
-    }
-
-    public static void loadActionClass(String actionClass) {
-        LOG.debug("load action class {}", actionClass);
-        try {
-            IAction ia = (IAction) Class.forName(actionClass).getDeclaredConstructor().newInstance();
-            // this happens during the server startup, so the cache must be empty. No need to check.
-            ruleEngine.actionClassCache.put(actionClass, ia);
-        } catch (Exception e) {
-            LOG.error("Exception:", e);
-            throw new RuntimeException("Could not find rule action class " + actionClass, e);
-        }
-    }
-
     public static Map<String, String> convertMapValueToString(Map<String, Object> originalMap) {
         Map<String, String> convertedMap = new HashMap<>();
         for (Map.Entry<String, Object> entry : originalMap.entrySet()) {