| | |
| | | return BindingBuilder.bind(orderDelayQueueFlow()).to(orderDelayExchangeFlow()).with(QueueEnum.GFA_ZY_TIME_FLOW.getRoute()); |
| | | } |
| | | // === 延时产出 end === |
| | | |
| | | |
| | | |
| | | //滑点 start |
| | | @Bean |
| | | public DirectExchange gfaZhiYaHuaDianExchange() { |
| | | return new DirectExchange(QueueEnum.GFA_ZY_HUA_DIAN.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue gfaZhiYaHuaDianQueue() { |
| | | return new Queue(QueueEnum.GFA_ZY_HUA_DIAN.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding gfaZhiYaHuaDianBind() { |
| | | return BindingBuilder.bind(gfaZhiYaHuaDianQueue()).to(gfaZhiYaHuaDianExchange()).with(QueueEnum.GFA_ZY_HUA_DIAN.getRoute()); |
| | | } |
| | | //滑点 end |
| | | } |