使用apache camel在Spring Boot中创建消息队列

Question

我是这个消息队列的新手，刚刚开始学习一些基本的东西。

因此，对于我们的Spring Boot应用程序，我们遵循了contoller talks to service&service talks to repository这样的体系结构，所以在这里，我必须创建一个控制器，它将接受类DTO作为json，并将这些信息发布到apache Camel中指定的消息队列。我在跟踪这个链接！对于我的参考，工作良好，但当我试图实现它在我的项目，它说我一个错误列出如下。

误差

@RestController
@RequestMapping("/deviceinfo")
public class TrackerQueueController {
@Autowired
CamelContext camelContext;

@Autowired
private
ProducerTemplate producerTemplate;

@PostMapping()
public void startCamel(@RequestBody FieldUpdate fieldUpdate) {
    producerTemplate.sendBody("activemq:topic:in", fieldUpdate);
}
}

   @Component
public class TrackerQueueRoutes extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("activemq:topic:in")
                .process(new TrackerProcessor() {
                    @Override
                    public void process(Exchange exchange) throws 
Exception {
                        log.info("I'm in");
                        FieldUpdate body = 
exchange.getIn().getBody(FieldUpdate.class);
                    log.info("Hello from camel processed message! 
Received payload: {}" , body.getSerialNumber());

exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 
HttpStatus.ACCEPTED);
                    }
            });
    }
}

处理机

public class TrackerProcessor implements Processor {
    @Override
   public void process(Exchange exchange) throws Exception {

   }
}

可以任何一个提供给我一些教程链接，满足我的需要或任何想法。

Answer 1

正如Claus Ibsen在评论中建议的，您必须将这些依赖项添加到您的POM文件中

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-spring-boot-starter</artifactId>
    <version>[camel-version]</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

• camel-spring-boot-starter自动为您启动camelcontext，发现路由等
• spring-boot-starter-web通过侦听web请求来保持应用程序的运行。否则，它将在启动后立即关闭，因为没有任何可执行的内容。

由于您的Camel route类被正确地注释(@component)和子类(Extends RouteBuilder)，因此Camel SpringBoot Starter应该会自动发现它。