Merge pull request #31 from lasanthaS/master

Bump Siddhi version and fix test failure

Author: pcnfernando

Tests/SiddhiCoreTests/TestOutputStream.py

@@ -44,8 +44,7 @@ def getCount(self, event):
     def test_outputstram(self):
         logging.info("OutputStream Test 1: Test reception of events")
         siddhiManager = SiddhiManager()
-        cseEventStream = "@config(async = 'true') " \
-                         "define stream cseEventStream (symbol string, price float, volume int);"
+        cseEventStream = "define stream cseEventStream (symbol string, price float, volume int);"
 
         query = "@info(name = 'query 1') from cseEventStream select symbol, price, volume insert into OutputStream; "
 
@@ -58,6 +57,7 @@ def receive(self, events):
                 _self_shaddow.inEventCount.addAndGet(len(events))
 
         siddhiAppRuntime.addCallback("OutputStream", StreamCallbackImpl())
+        siddhiAppRuntime.start()
 
         inputHandler = siddhiAppRuntime.getInputHandler("cseEventStream")
 

__PySiddhiProxy/pom.xml

@@ -30,7 +30,7 @@
         <dependency>
             <groupId>io.siddhi</groupId>
             <artifactId>siddhi-core</artifactId>
-            <version>5.1.5</version>
+            <version>5.1.7</version>
         </dependency>
     </dependencies>
 
@@ -224,4 +224,4 @@
         </pluginRepository>
 
     </pluginRepositories>
-</project>
+</project>