From de77cce102cc455728f1a037cbd91d3f60531ba1 Mon Sep 17 00:00:00 2001
From: dilini-muthumala <dilini@wso2.com>
Date: Thu, 22 Apr 2021 21:48:18 +0530
Subject: [PATCH] Add testcase for
 https://github.com/siddhi-io/siddhi/issues/1542

---
 .../core/query/trigger/TriggerTestCase.java   | 36 +++++++++++++++++++
 1 file changed, 36 insertions(+)

diff --git a/modules/siddhi-core/src/test/java/io/siddhi/core/query/trigger/TriggerTestCase.java b/modules/siddhi-core/src/test/java/io/siddhi/core/query/trigger/TriggerTestCase.java
index b7e68148fd..65d8ea9dd9 100644
--- a/modules/siddhi-core/src/test/java/io/siddhi/core/query/trigger/TriggerTestCase.java
+++ b/modules/siddhi-core/src/test/java/io/siddhi/core/query/trigger/TriggerTestCase.java
@@ -210,4 +210,40 @@ public void receive(Event[] events) {
 
     }
 
+    @Test(dependsOnMethods = "testQuery7")
+    public void testQuery8() throws InterruptedException {
+        //see https://github.com/siddhi-io/siddhi/issues/1542
+        log.info("test case for https://github.com/siddhi-io/siddhi/issues/1542");
+
+        SiddhiManager siddhiManager = new SiddhiManager();
+
+        String plan = "" +
+                "define trigger AlertTypeReadTrigger at 'start';" +
+                "@sink(type='log')\n" +
+                "define stream logStream (foo string);\n" +
+                "\n" +
+                "from AlertTypeReadTrigger\n" +
+                "select \"hello\" as foo\n" +
+                "insert into logStream;";
+
+        SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(plan);
+
+        siddhiAppRuntime.addCallback("logStream", new StreamCallback() {
+
+            @Override
+            public void receive(Event[] events) {
+                EventPrinter.print(events);
+                count += events.length;
+                eventArrived = true;
+            }
+        });
+
+        siddhiAppRuntime.start();
+
+        Thread.sleep(1000);
+        siddhiAppRuntime.shutdown();
+        AssertJUnit.assertEquals(1, count);
+        AssertJUnit.assertEquals(true, eventArrived);
+    }
+
 }