本文主要是介绍spring AMQP代码生成rabbitmq的exchange and queue教程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
《springAMQP代码生成rabbitmq的exchangeandqueue教程》使用SpringAMQP代码直接创建RabbitMQexchange和queue,并确保绑定关系自动成立,简...
spring AMQP代码生成rabbitmq的exchange and queue
@Configuration public class FanoutConfigure { @Bean public FanoutExchange fanoutExchange() { return ExchangeBuilder.fanoutExchange(FANOUT_BUILDER_EXCHANGE_NAME).build(); // return new FanoutExchange(FANOUT_BUILDER_EXCHANGE_NAME); } @Bean public Queue fanoutQueue() { // return new Queue(FANOUT_BUILDER_QUEUE_NAME, true); javascript return QueueBuilder.durable(FANOUT_BUILDER_QUEUE_NAME).androidbuild(); } @Bean public Binding fanoutBinding(FanoutExchange fanoutExchange, Queue fanoutQueue) { // .with 实现 routingKey 的匹配 return BindingBuilder.bind(fanoutQueue).to(fanoutExchange); } }
直接上代码
public static final String FANOUT_BUILDER_EXCHANGE_NAphpME = "fanoutbuild.exchange"; public static final String FANOUT_BUILDER_QUEUE_NAME = "fanoutbuil编程d.queue";
执行结果
绑定关系成立。
总结
这篇关于spring AMQP代码生成rabbitmq的exchange and queue教程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!