Add supported protocols to GeoFlinkInit
@@ -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.processor.geo.flink.config.GeoFlinkConfig;
import org.streampipes.processor.geo.flink.processor.gridenricher.SpatialGridEnrichmentController;
@@ -37,6 +39,9 @@ public class GeoFlinkInit extends StandaloneModelSubmitter {
new SmileDataFormatFactory(),
new FstDataFormatFactory());
+ DeclarersSingleton.getInstance().registerProtocols(new SpKafkaProtocolFactory(),
+ new SpJmsProtocolFactory());
+
new GeoFlinkInit().init(GeoFlinkConfig.INSTANCE);
}
