Skip to content
Snippets Groups Projects
Commit 77291ecc authored by Constantin Jucovschi's avatar Constantin Jucovschi
Browse files

adding hot deploy

parent 8c3be79a
No related branches found
No related tags found
No related merge requests found
Showing with 32 additions and 13 deletions
File added
......@@ -62,7 +62,7 @@ felix.auto.deploy.action=install,start
# The following property specifies the directory to use as the bundle
# auto-deploy directory; the default is 'bundle' in the working directory.
#felix.auto.deploy.dir=bundle
felix.auto.deploy.dir=bundle
# The following property is a space-delimited list of bundle URLs
# to install when the framework starts. The ending numerical component
......@@ -98,3 +98,6 @@ felix.log.level=1
org.osgi.service.http.port=8080
obr.repository.url=http://felix.apache.org/obr/releases.xml
felix.fileinstall.dir=./bundle-dev
\ No newline at end of file
......@@ -76,7 +76,7 @@
<plugin>
<groupId>org.apache.felix</groupId>
<artifactId>maven-ipojo-plugin</artifactId>
<version>1.6.0</version>
<version>1.11.2</version>
<executions>
<execution>
<goals>
......
......@@ -11,14 +11,6 @@ public class DocumentManagerRoutes extends RouteBuilder {
public static final String directSallyRegisterQueue = "direct:/queue/sally_register";
public static final String mockSallyRegisterQueueOutput = "mock:/queue/sally_register_out";
/*
RegisterProcessor registerProcessor;
public SallyRegisterRoute(RegisterProcessor registerProcessor) {
this.registerProcessor = registerProcessor;
}
*/
@Override
public void configure() throws Exception {
DataFormat core = CommUtils.getDataFormat("core");
......
......@@ -42,15 +42,15 @@ public class MathHubWorkerImpl implements MathHubWorker {
public void configure() throws Exception {
from("direct:getUserForSessionID")
.id("getUserFromPlanetary")
.to("planetary:select uid from sessions where sid=#")
.to("log:foo");
.to("planetary:select uid from sessions where sid=#?outputType=SelectOne");
from("activemq:")
}
}
@Validate
public void start() {
log.info("--------- STARTING ----------------");
camelContext = camelContextProvider.getSallyCamelContext();
try {
camelContext.addRoutes(new MyRoute());
......
package info.kwarc.sally4.mathhubworker.impl;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class UserBasedRouter implements Processor{
Logger log;
public UserBasedRouter() {
log = LoggerFactory.getLogger(getClass());
}
public void process(Exchange exchange) throws Exception {
log.info(exchange.getIn().getBody().toString());
// List<Map<String, Long>> uids = (List<Map<String, Long>>)exchange.getIn().getBody();
// for (Map<String, Long> uid: uids) {
// log.info(uid.get("uid").toString());
// }
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment