<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-cdi</artifactId>
<version>3.12.0</version>
</dependency>
@ApplicationScoped
public class MyCamelContext {
@Produces
@ApplicationScoped
public CamelContext createCamelContext() {
CamelContext context = new DefaultCamelContext();
context.addRoutes(new MyRouteBuilder());
return context;
}
}
@ApplicationScoped
public class MyRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
from("timer:myTimer?period=5000")
.setBody().simple("Hello Camel!")
.to("log:myLogger");
}
}
@Inject
private CamelContext camelContext;
@PostConstruct
public void init() throws Exception {
camelContext.start();
}
