diff --git a/ch.psi.fda/src/main/java/ch/psi/fda/rest/CdumpEngine.java b/ch.psi.fda/src/main/java/ch/psi/fda/rest/CdumpEngine.java
index 6c76970..e719ae2 100644
--- a/ch.psi.fda/src/main/java/ch/psi/fda/rest/CdumpEngine.java
+++ b/ch.psi.fda/src/main/java/ch/psi/fda/rest/CdumpEngine.java
@@ -72,7 +72,8 @@ public class CdumpEngine {
 		stream = (request.getStream()!=null && request.getStream().getIds().length>0) ;
 		if(stream){
 			// Stream data via ZMQ
-			zmqService.setTrackingId(trackingId); 
+			zmqService.setTrackingId(trackingId);
+			// TODO set id filter !!!
 			bus.register(zmqService);
 		}
 		
diff --git a/ch.psi.fda/src/main/java/ch/psi/fda/rest/FdaqEngine.java b/ch.psi.fda/src/main/java/ch/psi/fda/rest/FdaqEngine.java
index 80b6ee0..7c65ca9 100644
--- a/ch.psi.fda/src/main/java/ch/psi/fda/rest/FdaqEngine.java
+++ b/ch.psi.fda/src/main/java/ch/psi/fda/rest/FdaqEngine.java
@@ -66,7 +66,8 @@ public class FdaqEngine {
 		stream = (request.getStream()!=null && request.getStream().getIds().length>0) ;
 		if(stream){
 			// Stream data via ZMQ
-			zmqService.setTrackingId(trackingId); 
+			zmqService.setTrackingId(trackingId);
+			// TODO Set id filter !!!!
 			bus.register(zmqService);
 		}