From 9d6ae89f13a1fd08199847ea9a35547ffec1b030 Mon Sep 17 00:00:00 2001 From: Simon Ebner Date: Thu, 9 Jan 2014 09:17:27 +0100 Subject: [PATCH] Added TODO comment for reminding that filtering is not yet done --- ch.psi.fda/src/main/java/ch/psi/fda/rest/CdumpEngine.java | 3 ++- ch.psi.fda/src/main/java/ch/psi/fda/rest/FdaqEngine.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) 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); }