Added supportet protocols
@@ -23,6 +23,8 @@ import org.streampipes.dataformat.cbor.CborDataFormatFactory;
import org.streampipes.dataformat.fst.FstDataFormatFactory;
import org.streampipes.dataformat.json.JsonDataFormatFactory;
import org.streampipes.dataformat.smile.SmileDataFormatFactory;
+import org.streampipes.messaging.jms.SpJmsProtocolFactory;
+import org.streampipes.messaging.kafka.SpKafkaProtocolFactory;
import org.streampipes.processors.transformation.flink.config.TransformationFlinkConfig;
import org.streampipes.processors.transformation.flink.processor.boilerplate.BoilerplateController;
import org.streampipes.processors.transformation.flink.processor.converter.FieldConverterController;
@@ -47,6 +49,9 @@ public class TransformationFlinkInit extends StandaloneModelSubmitter {
new SmileDataFormatFactory(),
new FstDataFormatFactory());
+ DeclarersSingleton.getInstance().registerProtocols(new SpKafkaProtocolFactory(),
+ new SpJmsProtocolFactory());
+
new TransformationFlinkInit().init(TransformationFlinkConfig.INSTANCE);
}
