public void onServiceStarted()

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

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

  public void onServiceStarted(FunctionContext context) {
    LOG.info("Service started");
    this.outputCollector = context.getOutputCollectors().get(STREAM_APP_ID);
  }