Apache Camel

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 final 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 final 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

Apache Camel Quartz2 Maven Repository Apache Camel Mina2 Maven Repository Apache Camel HL7 Maven Repository Apache Camel Spring Boot Examples Apache Camel Mina2 Components Apache Camel OnCompletion Apache Camel Mina2 Starter Apache Camel HL7 Starter Apache Camel Predicates Apache Camel Lifecycle

Apache Camel Spring Remoting