Fix bug in Siddhi-based numerical filter
@@ -19,6 +19,7 @@ package org.streampipes.processors.siddhi;
import org.streampipes.container.init.DeclarersSingleton;
import org.streampipes.container.standalone.init.StandaloneModelSubmitter;
import org.streampipes.dataformat.json.JsonDataFormatFactory;
+import org.streampipes.messaging.jms.SpJmsProtocolFactory;
import org.streampipes.messaging.kafka.SpKafkaProtocolFactory;
import org.streampipes.processors.siddhi.config.FilterSiddhiConfig;
import org.streampipes.processors.siddhi.filter.NumericalFilterController;
@@ -32,6 +33,7 @@ public class FiltersSiddhiInit extends StandaloneModelSubmitter {
DeclarersSingleton.getInstance().registerDataFormat(new JsonDataFormatFactory());
DeclarersSingleton.getInstance().registerProtocol(new SpKafkaProtocolFactory());
+ DeclarersSingleton.getInstance().registerProtocol(new SpJmsProtocolFactory());
new FiltersSiddhiInit().init(FilterSiddhiConfig.INSTANCE);
}
