import org.apache.camel.builder.RouteBuilder;
import javax.inject.Inject;
import javax.inject.Named;
@Named
public class MyRoute extends RouteBuilder {
@Inject
private MyProcessor myProcessor;
@Override
public void configure() throws Exception {
from("timer:myTimer?period=1000")
.process(myProcessor)
.to("log:myLog");
}
}
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import javax.inject.Named;
@Named
public class MyProcessor implements Processor {
@Override
public void process(Exchange exchange) throws Exception {
}
}
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>
classpath:META-INF/camel-context.xml
</param-value>
</context-param>
<listener>
<listener-class>org.apache.camel.cdi.CdiCamelContextLoaderListener</listener-class>
</listener>
