diff --git a/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java b/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java index 715fd2a..769e035 100644 --- a/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java +++ b/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java @@ -254,7 +254,12 @@ public class DummyCassandraReader implements CassandraReader { i -> i * 10, i -> 0, i -> i, - query.getChannel()).stream(); + query.getChannel()) + .stream() + .map(metaPulse -> { + metaPulse.setKeyspace(KEYSPACE); + return metaPulse; + }); } /**