[feat]: add ark biz component

hellochenpg · Dec 8, 2021 · 7f45336 · 7f45336
1 parent d23b5da
commit 7f45336
Showing 1 changed file with 6 additions and 14 deletions.
diff --git a/...iver/src/main/java/com/zmops/zeus/iot/server/receiver/provider/CamelReceiverProvider.java b/...iver/src/main/java/com/zmops/zeus/iot/server/receiver/provider/CamelReceiverProvider.java
@@ -1,10 +1,10 @@
 package com.zmops.zeus.iot.server.receiver.provider;
 
 import com.zmops.zeus.iot.server.receiver.Const;
+import com.zmops.zeus.iot.server.receiver.handler.ark.ArkBizComponent;
+import com.zmops.zeus.iot.server.receiver.handler.zabbix.ZabbixSenderComponent;
 import com.zmops.zeus.iot.server.receiver.module.CamelReceiverModule;
-import com.zmops.zeus.iot.server.receiver.routes.PgEventRouteBuilder;
 import com.zmops.zeus.iot.server.receiver.service.CamelContextHolderService;
-import com.zmops.zeus.iot.server.receiver.tozabbix.ZabbixSenderComponent;
 import com.zmops.zeus.iot.server.sender.module.ZabbixSenderModule;
 import com.zmops.zeus.server.library.module.*;
 import org.apache.camel.impl.DefaultCamelContext;
@@ -46,27 +46,19 @@ public void prepare() throws ServiceNotProvidedException, ModuleStartException {
 
     @Override
     public void start() throws ServiceNotProvidedException, ModuleStartException {
-
         camelContext.addComponent(Const.CAMEL_ZABBIX_COMPONENT_NAME, new ZabbixSenderComponent(getManager()));
+        camelContext.addComponent(Const.CAMEL_ARK_COMPONENT_NAME, new ArkBizComponent(getManager()));
+    }
 
-        try {
-            camelContext.addRoutes(new PgEventRouteBuilder());
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-
+    @Override
+    public void notifyAfterCompleted() throws ServiceNotProvidedException, ModuleStartException {
         try {
             camelContext.start();
         } catch (Exception e) {
             e.printStackTrace();
         }
     }
 
-    @Override
-    public void notifyAfterCompleted() throws ServiceNotProvidedException, ModuleStartException {
-
-    }
-
     @Override
     public String[] requiredModules() {
         return new String[]{