diff --git a/modules/siddhi-launcher/src/main/java/org/wso2/siddhi/sdk/launcher/run/SiddhiRun.java b/modules/siddhi-launcher/src/main/java/org/wso2/siddhi/sdk/launcher/run/SiddhiRun.java index 436f920..14e9799 100644 --- a/modules/siddhi-launcher/src/main/java/org/wso2/siddhi/sdk/launcher/run/SiddhiRun.java +++ b/modules/siddhi-launcher/src/main/java/org/wso2/siddhi/sdk/launcher/run/SiddhiRun.java @@ -37,24 +37,21 @@ public SiddhiRun() { public void runSiddhi(String siddhiApp, String inputFile) throws InterruptedException { - while (true) { - try { - //Generating runtime - SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(siddhiApp); - - //Starting event processing - siddhiAppRuntime.start(); - - if (!(inputFile == null || inputFile.equalsIgnoreCase(""))) { - InputFeeder inputFeeder = new InputFeeder(siddhiAppRuntime, inputFile); - //starting input feeder - inputFeeder.start(); - break; - } - } catch (Exception e) { - log.error("Internal Siddhi Error Occurred: " + e); - break; + try { + //Generating runtime + SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(siddhiApp); + + //Starting event processing + siddhiAppRuntime.start(); + + if (!(inputFile == null || inputFile.equalsIgnoreCase(""))) { + InputFeeder inputFeeder = new InputFeeder(siddhiAppRuntime, inputFile); + //starting input feeder + inputFeeder.start(); } + } catch (Throwable e) { + log.error("Internal Siddhi Error Occurred: " + e); } + } } diff --git a/pom.xml b/pom.xml index 10c38d8..f1fefab 100644 --- a/pom.xml +++ b/pom.xml @@ -177,6 +177,11 @@ siddhi-execution-tensorflow ${siddhi.execution.tensorflow.version} + + org.wso2.extension.siddhi.execution.env + siddhi-execution-env + ${siddhi.execution.env.version} + org.wso2.extension.siddhi.io.jms @@ -276,6 +281,11 @@ siddhi-store-hbase ${siddhi.store.hbase.version} + + org.wso2.extension.siddhi.store.cassandra + siddhi-store-cassandra + ${siddhi.store.cassandra.version} + org.wso2.extension.siddhi.io.mqtt siddhi-io-mqtt @@ -316,7 +326,7 @@ - 4.1.2 + 4.1.12 1.64 2.7.4 2.4.1 @@ -332,41 +342,43 @@ 4.0.10 4.0.9 4.0.10 - 4.0.21 + 4.0.22 4.0.8 4.0.10 - 4.0.8 + 4.0.9 4.0.10 - 4.0.10 - 4.0.15 + 4.0.11 + 4.0.16 1.0.10 4.0.9 - 1.0.11 + 1.0.13 1.0.7 1.0.1 + 1.0.1 - 1.0.5 - 2.0.13 - 1.0.20 - 1.0.9 - 1.0.13 + 1.0.6 + 2.0.15 + 1.0.21 + 1.0.12 + 1.0.14 1.0.17 - 4.1.3 + 4.1.5 4.0.12 1.0.18 - 4.0.15 + 4.0.18 4.0.10 1.0.10 - 1.0.13 + 1.0.14 4.0.11 1.0.10 1.0.0 1.0.13 - 4.0.15 - 1.0.14 - 4.0.6 + 4.0.17 + 1.0.15 + 4.0.7 + 1.0.3 4.0.8