zoukankan      html  css  js  c++  java
  • 关于Rabbitmq 指定交换机

    1. 系统启动时候,创建交换机和队列。不绑定交换机的话,创建的队列使用默认交换机

    但是注意:延迟消息,需要新建一个交换机来指定。默认的支持延迟

    @Configuration
    public class RabbitmqConfig {

    @Bean
    public Exchange delayExchange() {
    TopicExchange exchange = new TopicExchange("shop.delay");
    exchange.setDelayed(true);
    return exchange;
    }

    // 30分钟后取消订单
    @Bean
    public Queue cancelOrderDelayQueue() {
    return new Queue("shop.delay.cancelOrder");
    }
    @Bean
    public Binding cancelOrderDelayBinding() {
    return BindingBuilder.bind(cancelOrderDelayQueue()).to(delayExchange())
    .with("shop.delay.cancelOrder").noargs();
    }

    // 7天后确认收货
    @Bean
    public Queue confirmOrderDelayQueue() {
    return new Queue("shop.delay.confirmOrder");
    }
    @Bean
    public Binding confirmOrderDelayBinding() {
    return BindingBuilder.bind(confirmOrderDelayQueue()).to(delayExchange())
    .with("shop.delay.confirmOrder").noargs();
    }

    @Bean
    public Queue contractFinishQueue() {
    return new Queue("shop.contract.finish");
    }

    @Bean
    public Queue taskFinishQueue() {
    return new Queue("shop.task.finish");
    }
    }
  • 相关阅读:
    Delphi中WebBbrowser的编程 转
    博客园设置目录
    iTerm
    python
    谷歌浏览器插件的导出导入
    Chapter10 属性
    WPF之Binding
    ASP.NET 路由系统
    Silverlight中使用Application.GetResourceStream方法加载资源时得到的总是null
    基于IoC的ControllerFactory
  • 原文地址:https://www.cnblogs.com/yanqb/p/15779157.html
Copyright © 2011-2022 走看看