stream name and host name updated for new GDN stream and table

FYP-Live-Query · Dec 15, 2022 · a0025ef · a0025ef
1 parent 500aa57
commit a0025ef
Show file tree

Hide file tree

Showing 5 changed files with 4 additions and 9 deletions.
diff --git a/component/src/main/java/io/siddhi/extension/io/live/source/LiveSource.java b/component/src/main/java/io/siddhi/extension/io/live/source/LiveSource.java
@@ -189,7 +189,7 @@ public void connect(ConnectionCallback connectionCallback , State state) throws
         pulsarClientTLSAuth = new PulsarClientTLSAuth(apiKey,serviceURLOfPulsarServer);
 
         consumerThread = new StreamThread(
-                "madu140_gmail.com/c8local._system/network_traffic",pulsarClientTLSAuth,"my-subscriptionl",
+                "Tu_TZ0W2cR92-sr1j-l7ACA/c8local._system/NetworkTrafficTable",pulsarClientTLSAuth,"my-subscription",
                                 monitor,sourceEventListener
                 );
 

diff --git a/component/src/main/resources/SQLtoSiddhiQL-0.8.0-SNAPSHOT.jar b/component/src/main/resources/SQLtoSiddhiQL-0.8.0-SNAPSHOT.jar
diff --git a/component/src/main/resources/c84j-1.1.25.2-SNAPSHOT.jar b/component/src/main/resources/c84j-1.1.25.2-SNAPSHOT.jar
diff --git a/component/src/test/java/io/siddhi/extension/io/live/source/TestCaseOfLiveSource.java b/component/src/test/java/io/siddhi/extension/io/live/source/TestCaseOfLiveSource.java
@@ -1,8 +1,5 @@
 package io.siddhi.extension.io.live.source;
 
-import com.c8db.C8Cursor;
-import com.c8db.C8DB;
-import com.c8db.entity.BaseDocument;
 import io.siddhi.core.SiddhiAppRuntime;
 import io.siddhi.core.SiddhiManager;
 import io.siddhi.core.event.Event;
@@ -39,15 +36,13 @@ public void init() {
      */
     @Test
     public void liveSelect() throws Exception {
-//        List<String> receivedEventNameList = new ArrayList<>(2);
         PersistenceStore persistenceStore = new InMemoryPersistenceStore();
         SiddhiManager siddhiManager = new SiddhiManager();
         siddhiManager.setPersistenceStore(persistenceStore);
         String inStreamDefinition0 = "@App:name('TestSiddhiApp0')" +
-                "@source(type='live',sql.query='FOR t IN network_traffic COLLECT browser = t.browser WITH COUNT INTO value RETURN {browser: browser,totalCount: value}', " +
-                "host.name='api-varden-4f0f3c4f.paas.macrometa.io'," +
-                "api.key = 'madu140_gmail.com." +
-                "AccessPortal.2PL8EeyIAMn2sx7YHKWMM58tmJLES4NyIWq6Cnsj0BTMjygJyF3b14zb2sidcauXccccb8', " +
+                "@source(type='live',sql.query='FOR t IN NetworkTrafficTable COLLECT browser = t.browser WITH COUNT INTO value RETURN {browser: browser,totalCount: value}', " +
+                "host.name='api-peamouth-0b57f3c7.paas.macrometa.io'," +
+                "api.key = 'Tu_TZ0W2cR92-sr1j-l7ACA.newone.9pej9tihskpx2vYZaxubGW3sFCJLzxe55NRh7T0uk1JMYiRmHdiQsWh5JhRXXT6c418385', " +
                 " @map(type='json', fail.on.missing.attribute='false') )" +
                 "define stream inputStream (id String,key String,revision String,properties String);";
 

diff --git a/component/target/classes/SQLtoSiddhiQL-0.8.0-SNAPSHOT.jar b/component/target/classes/SQLtoSiddhiQL-0.8.0-SNAPSHOT.jar