Calling Apache Camel route from a REST controller

Question

I have a job that looks like this:

@Named
public class MyCamelRouteBuilder extends RouteBuilder {

    private static final String JOB_NAME = "abc";
    private static final String JOB_METHOD_NAME = "xyz";

    private final MyJob myJob;

    @Inject
    public MyCamelRouteBuilder(MyJob myJob) {
        super();
        this.myJob = myJob;
    }

    @Override
    public void configure() {
        fromF("direct:%s", JOB_NAME)
            .routeId(JOB_NAME)
            .bean(myJob, JOB_METHOD_NAME)
            .end();

        fromF("master:some_name_1/some_name_2:scheduler:%s?delay=%s", JOB_NAME, 1234)
            .routeId("JobTimer")
            .toF("direct:%s", JOB_NAME)
            .end();
    }
}

A very simplified version of the job class:

@Named
public class MyJob {

    private MyJob() {}
    }

    public void xyz() {

    }
}

This does work and it does gets triggered as expected.

The problem starts here:

Now, I also want to create a REST controller that will be able to trigger the exact same job. Something like this:

@Named
@RestController
@RequestMapping
@Validated
public class MyController {

    private static final String JOB_NAME = "abc";

    private final ProducerTemplate producerTemplate;

    @Inject
    public MyController(
            ProducerTemplate producerTemplate
    ) {

        this.producerTemplate = producerTemplate;
    }

    @PostMapping(path = "/my_endpoint")
    public String run() throws Exception {
        producerTemplate.requestBody("direct:" + JOB_NAME);
        return "ok";
    }
}

But once it reaches this line, the job is not triggered and the request call keeps hanging.

producerTemplate.requestBody("direct:" + JOB_NAME);

Any ideas?

Answer 1

The fix for my problem:

@Named
@RestController
@RequestMapping
@Validated
public class MyController {
    private static final String JOB_NAME = "abc";

    @Produce("direct:" + JOB_NAME)
    private final ProducerTemplate producerTemplate;
    private final CamelContext context;

    @Inject
    public MyController(
            ProducerTemplate producerTemplate, CamelContext context
    ) {
        this.producerTemplate = producerTemplate;
        this.context = context;
    }

    @PostMapping(path = "/my_endpoint")
    public String run() throws Exception {

        Exchange exchange = new DefaultExchange(context);
        producerTemplate.send(exchange);

        return "ok";
    }
}