我有一个类似这样的工作：

@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();
    }
}

作业类的一个非常简化的版本：

@Named
public class MyJob {

    private MyJob() {}
    }

    public void xyz() {

    }
}

这确实起作用了，而且确实按预期触发了。

问题从这里开始：

现在，我还想创建一个REST控制器，它将能够触发完全相同的作业。

@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";
    }
}

但是一旦到达这一行，作业就不会被触发，请求调用就会一直挂起。

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

有什么想法吗？