public void onEvent()

in streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/function/example/FunctionPublishExample.java [62:68]

• 7 lines of code
• 1 McCabe index (conditional complexity)

  public void onEvent(Event event, String streamId) {
    LOG.info("on event");
    var ev = new Event();
    ev.addField("timestamp", System.currentTimeMillis());
    ev.addField("example-property", "abc");
    this.outputCollector.collect(ev);
  }