我正在学习一个教程,关于使用SpringBoot ApacheCamel和RabbitMQ。我正处于这个阶段,我只想创建一个队列
代码如下
@SpringBootApplication
@ComponentScan(basePackages = {"com.cav.routes"})
public class CamelApacheMicroServiceAApplication {
public static void main(String[] args) {
SpringApplication.run(CamelApacheMicroServiceAApplication.class, args);
}
}
@Configuration
public class CamelConfiguration {
// name as rabbitConnectionFactory camel will autoimport it
@Bean
public ConnectionFactory rabbitConnectionFactory() {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);
factory.setUsername("guest");
factory.setPassword("guest");
return factory;
}
}
@Component
public class WeatherRouter extends RouteBuilder{
public static final String RABBIT_URI = "rabbitmq:amq.direct?queue=weather&routingKey=weather&autoDelete=false";
@Override
public void configure() throws Exception {
// TODO Auto-generated method stub
//define camel route
//rabbitmq:exchange
from(RABBIT_URI)
.log(ERROR, "Got this message from RabbitMQ: ${body}");
}
}
据我所知
from("rabbitmq:amq.direct?queue=weather&routingKey=weather&autoDelete=false")
型
应该创建一个名为weather的队列
但是当我查看我的rabbitmq时,队列还没有创建
我的POM是我正在使用Java 17与 Camel 3.7.3,这可能是问题所在。
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.8</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<groupId>com.cav.routes</groupId>
<artifactId>CamelApacheMicroServiceA</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>CamelApacheMicroServiceA</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>17</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
<version>3.7.3</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-rabbitmq</artifactId>
<version>3.7.3</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-rabbitmq</artifactId>
<version>3.7.3</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-jackson</artifactId>
<version>3.7.3</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
型
谢谢你的任何帮助
1条答案
按热度按时间g9icjywg1#
请参阅此网页:
https://github.com/apache/camel-spring-boot-examples/blob/main/rabbitmq/src/main/resources/application.properties
字符串