public SpServiceDefinition provideServiceDefinition()

in streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/function/example/FunctionExampleInit.java [22:42]

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

  public SpServiceDefinition provideServiceDefinition() {
    return SpServiceDefinitionBuilder.create("org.apache.streampipes.processors.examples.function",
            "StreamPipes Function Example",
            "",
            8090)
        //.registerFunction(new StreamPipesFunctionExample())
        .registerFunction(new FunctionPublishExample())
        .registerMessagingFormats(
            new JsonDataFormatFactory(),
            new CborDataFormatFactory(),
            new SmileDataFormatFactory(),
            new FstDataFormatFactory())
        .registerMessagingProtocols(
            new SpKafkaProtocolFactory(),
            new SpJmsProtocolFactory(),
            new SpMqttProtocolFactory(),
            new SpNatsProtocolFactory())
        .build();


  }