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 index 88b47ce..b7a5569 100644 --- 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 new file mode 100644 index 0000000..b1fee11 Binary files /dev/null and b/component/src/main/resources/SQLtoSiddhiQL-0.8.0-SNAPSHOT.jar differ 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 new file mode 100644 index 0000000..6521de5 Binary files /dev/null and b/component/src/main/resources/c84j-1.1.25.2-SNAPSHOT.jar differ 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 index f8fc47c..425ca62 100644 --- 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 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 new file mode 100644 index 0000000..b1fee11 Binary files /dev/null and b/component/target/classes/SQLtoSiddhiQL-0.8.0-SNAPSHOT.jar differ