Wie man Spring-RabbitMQ zum erstellen einer neuen Warteschlange?

Älterer thread, aber das zeigt noch bis ziemlich hoch auf Google, also hier ein paar neuere Informationen:

2015-11-23

Seit Frühjahr 4.2.x mit Feder-Messaging-und Spring-Amqp 1.4.5.RELEASE und Spring-Kaninchen 1.4.5.RELEASE, erklärt exchanges, queues und bindings hat sich sehr einfach durch ein @Configuration-Klasse einige Anmerkungen:

@EnableRabbit
@Configuration
@PropertySources({
    @PropertySource("classpath:rabbitMq.properties")
})
public class RabbitMqConfig {    
    private static final Logger logger = LoggerFactory.getLogger(RabbitMqConfig.class);

    @Value("${rabbitmq.host}")
    private String host;

    @Value("${rabbitmq.port:5672}")
    private int port;

    @Value("${rabbitmq.username}")
    private String username;

    @Value("${rabbitmq.password}")
    private String password;

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host, port);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);

        logger.info("Creating connection factory with: " + username + "@" + host + ":" + port);

        return connectionFactory;
    }

    /**
     * Required for executing adminstration functions against an AMQP Broker
     */
    @Bean
    public AmqpAdmin amqpAdmin() {
        return new RabbitAdmin(connectionFactory());
    }

    /**
     * This queue will be declared. This means it will be created if it does not exist. Once declared, you can do something
     * like the following:
     * 
     * @RabbitListener(queues = "#{@myDurableQueue}")
     * @Transactional
     * public void handleMyDurableQueueMessage(CustomDurableDto myMessage) {
     *    //Anything you want! This can also return a non-void which will queue it back in to the queue attached to @RabbitListener
     * }
     */
    @Bean
    public Queue myDurableQueue() {
        //This queue has the following properties:
        //name: my_durable
        //durable: true
        //exclusive: false
        //auto_delete: false
        return new Queue("my_durable", true, false, false);
    }

    /**
     * The following is a complete declaration of an exchange, a queue and a exchange-queue binding
     */
    @Bean
    public TopicExchange emailExchange() {
        return new TopicExchange("email", true, false);
    }

    @Bean
    public Queue inboundEmailQueue() {
        return new Queue("email_inbound", true, false, false);
    }

    @Bean
    public Binding inboundEmailExchangeBinding() {
        //Important part is the routing key -- this is just an example
        return BindingBuilder.bind(inboundEmailQueue()).to(emailExchange()).with("from.*");
    }
}

Einige Quellen und Dokumentation zu helfen:

1. Frühjahr Anmerkungen
2. Deklarieren/Konfiguration des RabbitMQ für die queue - /binding-Unterstützung
3. Direkte exchange-Bindung (wenn routing-Taste ist egal)

Hinweis: Sieht aus wie vermisste ich eine version-beginnend mit Spring AMQP 1.5, werden die Dinge sogar noch einfacher, da können Sie erklären, die volle Bindung direkt an den Hörer!

InformationsquelleAutor Jaymes Bearden

Können Sie fügen Sie diese, nach Ihrer Verbindung-tag, aber bevor der Hörer:

<rabbit:queue name="test" auto-delete="true" durable="false" passive="false" />

Leider, nach dem XSD-schema, das passive Attribut (siehe oben) ist nicht gültig. Jedoch, in jedem queue_declare Umsetzung, die ich gesehen habe, passiv wurde eine gültige queue_declare parameter. Ich bin gespannt, ob das funktionieren wird oder ob Sie planen, Sie zu unterstützen in Zukunft.

Hier ist die vollständige Liste der Optionen für eine Warteschlange Erklärung:
http://www.rabbitmq.com/amqp-0-9-1-reference.html#class.queue

Und hier ist die vollständige XSD-für die spring-Kaninchen-schema (mit Kommentaren):
http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd

InformationsquelleAutor Homer6