2016-07-27 34 views
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); 
       } 
      }; 
     } 
} 
+0

您是否在配置中添加了「RabbitAdmin」? – Nilan

+0

以上代碼是我的配置。我沒有在我的配置中添加任何「RabbitAdmin」。請讓我知道如何添加它。 – Chandan

回答

0

請參閱the documentation

只需添加<rabbit:queue ... /> beans和一個<rabbit:admin ... />,管理員將在首次建立連接時自動聲明隊列。

相關問題