Erstellen einer neuen Warteschlange mit Spring AMQP beim Start der Webanwendung

Question

Ich versuche eine neue Warteschlange in RabbitMQ mit Spring AMQP beim Serverstart meiner Webanwendung zu erstellen. Ich bekomme nicht den genauen Konfigurationscode, wie man es erreicht. Unten ist mein Code-Snippet. Bitte korrigieren Sie die folgenden.

@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); 
       } 
      }; 
     } 
} 

Answer 1

Siehe the documentation.

Fügen Sie einfach <rabbit:queue ... /> Beans und eine <rabbit:admin ... /> hinzu und der Admin wird automatisch die Warteschlangen beim ersten Verbindungsaufbau deklarieren.