| | |
| | | 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 === |
| | | |
| | | |
| | | // === nft卡牌盲盒 start === |
| | | @Bean |
| | | public DirectExchange nftBoxExchange() { |
| | | return new DirectExchange(QueueEnum.NFT_BOX.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue nftBoxQueue() { |
| | | return new Queue(QueueEnum.NFT_BOX.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding nftBoxBind() { |
| | | return BindingBuilder.bind(nftBoxQueue()).to(nftBoxExchange()).with(QueueEnum.NFT_BOX.getRoute()); |
| | | } |
| | | // === nft卡牌盲盒 end === |
| | | } |