0
我想在我的web應用程序的服務器啓動時使用Spring AMQP在RabbitMQ中創建一個新隊列。我沒有得到確切的配置代碼如何實現它。 以下是我的代碼片段。請更正以下內容。在web應用程序啓動時使用Spring AMQP創建一個新隊列
@Configuration
public class RabbitMQConfiguration {
@Bean
public ConnectionFactory rabbitConnectionFactory() {
CachingConnectionFactory connectionFactory = new CachingConnectionFactory("10.165.18.29");
connectionFactory.setUsername("User");
connectionFactory.setPassword("user");
return connectionFactory;
}
@Bean
public SimpleMessageListenerContainer messageListenerContainer() {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(rabbitConnectionFactory());
container.addQueueNames("create.queue");
container.setMessageListener(exampleListener());
return container;
}
@Bean
public MessageListener exampleListener() {
return new MessageListener() {
public void onMessage(Message message) {
System.out.println("received: " + message);
}
};
}
}
您是否在配置中添加了「RabbitAdmin」? – Nilan
以上代碼是我的配置。我沒有在我的配置中添加任何「RabbitAdmin」。請讓我知道如何添加它。 – Chandan