Merge pull request #11 from keyko-io/feature/change-split-topic-name

Concat contract name and name for view topics
keyko-io · Feb 17, 2020 · e5e5c58 · e5e5c58
2 parents a07af34 + 8aacdad
commit e5e5c58
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>io.keyko.monitoring</groupId>
   <artifactId>web3-event-streamer</artifactId>
-  <version>0.1.0</version>
+  <version>0.1.1</version>
   <name>Web3 Monitoring Event Streamer</name>
   <url>https://github.com/keyko-io/web3-event-streamer</url>
   <inceptionYear>2019</inceptionYear>

diff --git a/src/main/java/io/keyko/monitoring/postprocessing/Output.java b/src/main/java/io/keyko/monitoring/postprocessing/Output.java
@@ -38,7 +38,7 @@ public static void splitByEvent(KStream<String, EventBlockRecord> events, String
    */
   public static void splitByView(KStream<String, ViewBlockRecord> views, String suffix) {
     views.to((key, value, recordContext) ->
-        "w3m-".concat(value.getDetails().getName().toLowerCase()).concat(suffix),
+        "w3m-".concat(value.getDetails().getContractName().toLowerCase()).concat("-").concat(value.getDetails().getName().toLowerCase()).concat(suffix),
       Produced.with(Serdes.String(), Web3MonitoringSerdes.getViewBlockSerde())
     );
   }