diff --git a/build.gradle b/build.gradle index 22cfe27..e19e115 100644 --- a/build.gradle +++ b/build.gradle @@ -2,7 +2,7 @@ version = '1.0.0' dependencies { compile project(':ch.psi.daq.cassandra') - compile 'org.springframework.boot:spring-boot-starter-web:1.2.3.RELEASE' + compile 'org.springframework.boot:spring-boot-starter-web:1.2.4.RELEASE' compile 'org.apache.commons:commons-lang3:3.4' } diff --git a/debug/springloaded-1.2.3.RELEASE.jar b/debug/springloaded-1.2.3.RELEASE.jar new file mode 100644 index 0000000..7e8cb3f Binary files /dev/null and b/debug/springloaded-1.2.3.RELEASE.jar differ diff --git a/src/main/java/ch/psi/daq/rest/DaqController.java b/src/main/java/ch/psi/daq/rest/DaqController.java index 3435865..aab01c6 100644 --- a/src/main/java/ch/psi/daq/rest/DaqController.java +++ b/src/main/java/ch/psi/daq/rest/DaqController.java @@ -1,13 +1,32 @@ package ch.psi.daq.rest; +import java.util.UUID; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; -import ch.psi.daq.cassandra.ops.CassandraWriter; +import ch.psi.daq.cassandra.writer.CassandraWriter; +import ch.psi.daq.domain.cassandra.ChannelEvent; @RestController public class DaqController { - - @Autowired - private CassandraWriter writer; + + private static final Logger logger = LoggerFactory.getLogger(DaqController.class); + + @Autowired + private CassandraWriter writer; + + @RequestMapping(value = "/test") + public void queryIndices() { + + logger.info("TEST endpoint invoked"); + + long pulseId = System.currentTimeMillis(); + String value = "data_" + UUID.randomUUID().toString(); + + writer.writeAsync(1, 0, new ChannelEvent("dummyChannel", pulseId, 0, pulseId, pulseId, 0, value)); + } } diff --git a/src/main/java/ch/psi/daq/rest/DaqRestApplication.java b/src/main/java/ch/psi/daq/rest/DaqRestApplication.java index 05ad357..e2a965f 100644 --- a/src/main/java/ch/psi/daq/rest/DaqRestApplication.java +++ b/src/main/java/ch/psi/daq/rest/DaqRestApplication.java @@ -5,6 +5,9 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.boot.context.web.SpringBootServletInitializer; import org.springframework.context.annotation.ComponentScan; +import org.springframework.context.annotation.Import; + +import ch.psi.daq.cassandra.config.CassandraConfig; /** * Entry point to our rest-frontend of the Swissfel application which most importantly wires all the @RestController annotated classes. @@ -31,9 +34,16 @@ import org.springframework.context.annotation.ComponentScan; * them accordingly. */ @SpringBootApplication -@ComponentScan(basePackages = { "ch.psi.daq" }) +//@Import(CassandraConfig.class) // either define the context to be imported, or see ComponentScan comment below +@ComponentScan(basePackages = { + "ch.psi.daq.rest", + "ch.psi.daq.cassandra.config", // define the package name with the CassandraConfig configuration, or @Import it (see above) + "ch.psi.daq.cassandra.reader", + "ch.psi.daq.cassandra.writer" +}) public class DaqRestApplication extends SpringBootServletInitializer { + public static void main(final String[] args) { SpringApplication.run(DaqRestApplication.class, args); } @@ -42,4 +52,11 @@ public class DaqRestApplication extends SpringBootServletInitializer { protected final SpringApplicationBuilder configure(final SpringApplicationBuilder application) { return application.sources(DaqRestApplication.class); } + + // a nested configuration + // this guarantees that the ordering of the properties file is as expected + // see: https://jira.spring.io/browse/SPR-10409?focusedCommentId=101393&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-101393 +// @Configuration +// @Import(CassandraConfig.class) +// static class InnerConfiguration { } } diff --git a/src/main/resources/rest.properties b/src/main/resources/rest.properties new file mode 100644 index 0000000..919cb7d --- /dev/null +++ b/src/main/resources/rest.properties @@ -0,0 +1 @@ +cassandra.basekeyspace=daq_zellweger_rest \ No newline at end of file