| | |
| | | public Binding defaultBind() { |
| | | return BindingBuilder.bind(onlineTransferQueue()).to(onlineTransferExchange()).with(QueueEnum.ONLINE_TRANSFER.getRoute()); |
| | | } |
| | | |
| | | @Bean |
| | | public DirectExchange distribProfitExchange() { |
| | | return new DirectExchange(QueueEnum.DISTRIB_PROFIT.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue distribProfitQueue() { |
| | | return new Queue(QueueEnum.DISTRIB_PROFIT.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding distribProfitBind() { |
| | | return BindingBuilder.bind(distribProfitQueue()).to(distribProfitExchange()).with(QueueEnum.DISTRIB_PROFIT.getRoute()); |
| | | } |
| | | |
| | | // === 用户购买奖励 start === |
| | | @Bean |
| | | public DirectExchange userBuyRewardExchange() { |
| | | return new DirectExchange(QueueEnum.USER_BUY_REWARD.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue userBuyRewardQueue() { |
| | | return new Queue(QueueEnum.USER_BUY_REWARD.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding userBuyRewardBind() { |
| | | return BindingBuilder.bind(userBuyRewardQueue()).to(userBuyRewardExchange()).with(QueueEnum.USER_BUY_REWARD.getRoute()); |
| | | } |
| | | // === 用户购买奖励 end === |
| | | } |