diff --git a/.project b/.project index 56f8001..08328ec 100644 --- a/.project +++ b/.project @@ -5,6 +5,11 @@ + + org.eclipse.wst.common.project.facet.core.builder + + + org.eclipse.jdt.core.javabuilder @@ -20,5 +25,6 @@ org.springframework.ide.eclipse.core.springnature org.springsource.ide.eclipse.gradle.core.nature org.eclipse.jdt.core.javanature + org.eclipse.wst.common.project.facet.core.nature diff --git a/.settings/org.eclipse.jdt.core.prefs b/.settings/org.eclipse.jdt.core.prefs index 6d7fe6b..613af83 100644 --- a/.settings/org.eclipse.jdt.core.prefs +++ b/.settings/org.eclipse.jdt.core.prefs @@ -1,5 +1,5 @@ # -#Fri Nov 27 16:17:06 CET 2015 +#Mon Nov 30 11:01:36 CET 2015 org.eclipse.jdt.core.compiler.debug.localVariable=generate org.eclipse.jdt.core.compiler.compliance=1.8 org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve diff --git a/src/main/java/ch/psi/daq/queryrest/response/ResponseStreamWriter.java b/src/main/java/ch/psi/daq/queryrest/response/ResponseStreamWriter.java index de4e91d..7dba652 100644 --- a/src/main/java/ch/psi/daq/queryrest/response/ResponseStreamWriter.java +++ b/src/main/java/ch/psi/daq/queryrest/response/ResponseStreamWriter.java @@ -32,6 +32,8 @@ import ch.psi.daq.query.model.impl.DAQQuery; */ public class ResponseStreamWriter { + private static final String DATA_RESP_FIELD = "data"; + private static final Logger logger = LoggerFactory.getLogger(ResponseStreamWriter.class); @Resource @@ -114,7 +116,7 @@ public class ResponseStreamWriter { generator.writeStartObject(); generator.writeStringField(QueryField.channel.name(), entry.getKey()); - generator.writeFieldName("data"); + generator.writeFieldName(DATA_RESP_FIELD); writer.writeValue(generator, entry.getValue()); generator.writeEndObject(); diff --git a/src/main/resources/queryrest.properties b/src/main/resources/queryrest.properties index 9ee6bf6..bf99eef 100644 --- a/src/main/resources/queryrest.properties +++ b/src/main/resources/queryrest.properties @@ -1,6 +1,6 @@ # defines the fields that are included in the response # if no fields have been specified by the user -queryrest.default.response.fields=channel,pulseId,globalMillis,globalNanos,iocMillis,iocNanos,shape,value +queryrest.default.response.fields=channel,pulseId,globalMillis,globalNanos,iocMillis,iocNanos,shape,eventCount,value # aggregation which are included in the response by default if aggregation is enabled for a given query queryrest.default.response.aggregations=min,max,sum diff --git a/src/test/java/ch/psi/daq/test/queryrest/DaqWebMvcConfig.java b/src/test/java/ch/psi/daq/test/queryrest/DaqWebMvcConfig.java index 4ec664f..50f85b5 100644 --- a/src/test/java/ch/psi/daq/test/queryrest/DaqWebMvcConfig.java +++ b/src/test/java/ch/psi/daq/test/queryrest/DaqWebMvcConfig.java @@ -11,6 +11,7 @@ import org.springframework.web.servlet.config.annotation.EnableWebMvc; import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport; import ch.psi.daq.cassandra.reader.CassandraReader; +import ch.psi.daq.cassandra.util.test.CassandraDataGen; import ch.psi.daq.query.processor.QueryProcessor; import ch.psi.daq.query.processor.QueryProcessorLocal; import ch.psi.daq.test.cassandra.admin.CassandraTestAdmin; @@ -49,4 +50,10 @@ public class DaqWebMvcConfig extends WebMvcConfigurationSupport { public CassandraTestAdmin cassandraTestAdmin() { return new CassandraTestAdminImpl(); } + + @Bean + @Lazy + public CassandraDataGen cassandraDataGen() { + return new CassandraDataGen(); + } } \ No newline at end of file