Apache Camel: Difference between revisions
Jump to navigation
Jump to search
No edit summary |
No edit summary |
||
| Line 13: | Line 13: | ||
@Component | @Component | ||
public class | public class ScheduleRoute extends SpringRouteBuilder { | ||
private static Logger LOG = LoggerFactory.getLogger( | private static Logger LOG = LoggerFactory.getLogger(ScheduleRoute.class); | ||
@Autowired | @Autowired | ||
LabScheduleListener | LabScheduleListener scheduleListener; | ||
@Override | @Override | ||
public void configure() throws Exception { | public void configure() throws Exception { | ||
from("quartz2://lab/hl7v2/client/ | from("quartz2://lab/hl7v2/client/schedule?cron=*/1+*+*+*+*+?&trigger.timeZone=+8 UTC").routeId("labScheduleRoute") | ||
.process(new Processor() { | .process(new Processor() { | ||
@Override | @Override | ||
| Line 29: | Line 29: | ||
}) | }) | ||
.threads(1, 10).multicast() | .threads(1, 10).multicast() | ||
.bean(this. | .bean(this.scheduleListener).log("lab/hl7v2/client/schedule"); | ||
} | } | ||
} | } | ||
Revision as of 18:08, 22 December 2020
Route
package org.chorke.academia.java.mllp.engine.route;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.spring.SpringRouteBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.chorke.academia.java.mllp.engine.beans.listener.LabScheduleListener;
@Component
public class ScheduleRoute extends SpringRouteBuilder {
private static Logger LOG = LoggerFactory.getLogger(ScheduleRoute.class);
@Autowired
LabScheduleListener scheduleListener;
@Override
public void configure() throws Exception {
from("quartz2://lab/hl7v2/client/schedule?cron=*/1+*+*+*+*+?&trigger.timeZone=+8 UTC").routeId("labScheduleRoute")
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
LOG.debug("Keep your exchange business here");
}
})
.threads(1, 10).multicast()
.bean(this.scheduleListener).log("lab/hl7v2/client/schedule");
}
}
Handler
package org.chorke.academia.java.mllp.engine.beans.listener;
import org.apache.camel.Exchange;
import org.apache.camel.ExchangeException;
import org.apache.camel.Handler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
public class LabScheduleListenerImpl implements LabScheduleListener {
private static Logger LOG = LoggerFactory.getLogger(LabScheduleListenerImpl.class);
@Handler
@Override
public void listen(@ExchangeException Exception exception, Exchange exchange) throws Exception {
LOG.info("Keep your LAB schedule business here");
}
}
References
|
|