Создание новой очереди с использованием Spring AMQP при запуске веб-приложения

Я пытаюсь создать новую очередь в 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);
                }
            };
        }
}

person Chandan    schedule 27.07.2016    source источник
comment
Вы добавили RabbitAdmin в свою конфигурацию?   -  person Nilan    schedule 27.07.2016
comment
любой приведенный выше код является моей конфигурацией. я не добавил RabbitAdmin в свою конфигурацию. Пожалуйста, дайте мне знать, как добавить его.   -  person Chandan    schedule 27.07.2016


Ответы (1)


См. документацию.

Просто добавьте <rabbit:queue ... /> bean-компоненты и <rabbit:admin ... />, и администратор автоматически объявит очереди при первом установлении соединения.

person Gary Russell    schedule 27.07.2016