Я пытаюсь создать новую очередь в RabbitMQ, используя 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
в свою конфигурацию? - person Nilan   schedule 27.07.2016RabbitAdmin
в свою конфигурацию. Пожалуйста, дайте мне знать, как добавить его. - person Chandan   schedule 27.07.2016