Added oppSensor_* as allowed sensors

antoineauger · Jun 29, 2017 · fb74672 · fb74672
1 parent 552ef8e
commit fb74672
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/fr/isae/iqas/pipelines/IngestPipeline.java b/src/main/java/fr/isae/iqas/pipelines/IngestPipeline.java
@@ -66,6 +66,9 @@ public Graph<FlowShape<ConsumerRecord<byte[], String>, ProducerRecord<byte[], St
 
                     final FlowShape<RawData, RawData> filteredInformationBySensor = builder.add(
                             Flow.of(RawData.class).filter(r -> {
+                                if (r.getProducer().startsWith("oppSensor_")) {
+                                    return true;
+                                }
                                 String[] allowedSensors = getParams().get("allowed_sensors").split(";");
                                 List<String> allowedSensorList = Arrays.asList(allowedSensors);
                                 return allowedSensorList.contains(r.getProducer());