Comment obtenir Spring RabbitMQ pour créer une nouvelle file d'attente?

Plus vieux thread, mais cela montre encore assez élevé sur Google, voici donc quelques nouveaux renseignements:

2015-11-23

Depuis Printemps 4.2.x avec Ressort de Messagerie et Printemps-Amqp 1.4.5.COMMUNIQUÉ de et Printemps-Lapin 1.4.5.COMMUNIQUÉ dedéclarant échanges, les files d'attente et des liaisons est devenu très simple grâce à un @classe de Configuration de certaines annotations:

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

Certaines sources et de la documentation pour aider:

1. Le printemps des annotations
2. Déclarant/configuration RabbitMQ pour la file d'attente/en charge de la liaison
3. L'échange Direct de liaison (lors de l'acheminement de la clé n'a pas d'importance)

Note: il Semble que j'ai manqué une version, à commencer par la Printemps AMQP 1.5les choses deviennent encore plus facile, vous pouvez déclarer le plein droit contraignant à l'auditeur!

Pouvez-vous ajouter cet après votre balise de connexion, mais avant de l'auditeur:

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

Malheureusement, selon le schéma XSD, le passif de l'attribut (ci-dessus) n'est pas valide. Cependant, dans tous les queue_declare mise en œuvre que j'ai vu, passive a été valide queue_declare paramètre. Je suis curieux de voir si cela va fonctionner ou s'ils ont l'intention de le soutenir dans l'avenir.

Voici la liste complète des options pour une file d'attente de la déclaration:
http://www.rabbitmq.com/amqp-0-9-1-reference.html#class.queue

Et ici, c'est la pleine XSD pour le printemps lapin schéma (avec des commentaires):
http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd