File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -44,8 +44,7 @@ def getCount(self, event):
44
44
def test_outputstram (self ):
45
45
logging .info ("OutputStream Test 1: Test reception of events" )
46
46
siddhiManager = SiddhiManager ()
47
- cseEventStream = "@config(async = 'true') " \
48
- "define stream cseEventStream (symbol string, price float, volume int);"
47
+ cseEventStream = "define stream cseEventStream (symbol string, price float, volume int);"
49
48
50
49
query = "@info(name = 'query 1') from cseEventStream select symbol, price, volume insert into OutputStream; "
51
50
@@ -58,6 +57,7 @@ def receive(self, events):
58
57
_self_shaddow .inEventCount .addAndGet (len (events ))
59
58
60
59
siddhiAppRuntime .addCallback ("OutputStream" , StreamCallbackImpl ())
60
+ siddhiAppRuntime .start ()
61
61
62
62
inputHandler = siddhiAppRuntime .getInputHandler ("cseEventStream" )
63
63
You can’t perform that action at this time.
0 commit comments