[incubator-streampipes-extensions] branch edge-extensions updated: Introduced MQTT Logging

[go...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gomm pushed a commit to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git


The following commit(s) were added to refs/heads/edge-extensions by this push:
     new 2ad1993  Introduced MQTT Logging
2ad1993 is described below

commit 2ad19935bbe16bc94157f281b29a12949d2e6f80
Author: daniel-gomm <da...@outlook.de>
AuthorDate: Tue Jun 22 16:39:00 2021 +0200

    Introduced MQTT Logging
---
 .../processors/filters/jvm/processor/dummy/DummyController.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/dummy/DummyController.java b/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/dummy/DummyController.java
index dce8391..cab379d 100644
--- a/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/dummy/DummyController.java
+++ b/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/dummy/DummyController.java
@@ -38,6 +38,7 @@ import org.apache.streampipes.wrapper.standalone.StreamPipesReconfigurableProces
 public class DummyController extends StreamPipesReconfigurableProcessor {
 
   private static double reconfigurableValue;
+  private int nrRuns = 1;
 
   @Override
   public DataProcessorDescription declareModel() {
@@ -82,9 +83,8 @@ public class DummyController extends StreamPipesReconfigurableProcessor {
 
   @Override
   public void onReconfigurationEvent(Event event) throws SpRuntimeException {
-    Object[] obs = {System.currentTimeMillis(), String.format("Dummy processor reconfigured with value %s", event.getFieldByRuntimeName("i-am-reconfigurable").getAsPrimitive().getAsDouble())};
-    EvaluationLogger.getInstance().addLine(obs);
+    Object[] obs = {System.currentTimeMillis(), "processor reconfigured", nrRuns++, event.getFieldByRuntimeName("i-am-reconfigurable").getAsPrimitive().getAsDouble()};
+    EvaluationLogger.getInstance().logMQTT("Reconfiguration", obs);
     reconfigurableValue = event.getFieldByRuntimeName("i-am-reconfigurable").getAsPrimitive().getAsDouble();
-    EvaluationLogger.getInstance().writeOut();
   }
 }