| | |
| | | return BindingBuilder.bind(allMemberPerkAvaQueue()).to(allMemberPerkAvaExchange()).with(QueueEnum.ALL_MEMBER_PERK_AVA.getRoute()); |
| | | } |
| | | // === A k线数据 end === |
| | | |
| | | |
| | | // === A 合约铸造ANDAO start === |
| | | @Bean |
| | | public DirectExchange contractAnDaoExchange() { |
| | | return new DirectExchange(QueueEnum.CONTRACT_AN_DAO.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue contractAnDaoQueue() { |
| | | return new Queue(QueueEnum.CONTRACT_AN_DAO.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding contractAnDaoBind() { |
| | | return BindingBuilder.bind(contractAnDaoQueue()).to(contractAnDaoExchange()).with(QueueEnum.CONTRACT_AN_DAO.getRoute()); |
| | | } |
| | | // === A 合约铸造ANDAO end === |
| | | |
| | | |
| | | // === A 合约铸造ANDAO start === |
| | | @Bean |
| | | public DirectExchange contractAnDaoInExchange() { |
| | | return new DirectExchange(QueueEnum.ANT_A_CION_IN_CONTRACT.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue contractAnDaoInQueue() { |
| | | return new Queue(QueueEnum.ANT_A_CION_IN_CONTRACT.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding contractAnDaoInBind() { |
| | | return BindingBuilder.bind(contractAnDaoInQueue()).to(contractAnDaoInExchange()).with(QueueEnum.ANT_A_CION_IN_CONTRACT.getRoute()); |
| | | } |
| | | // === A 合约铸造ANDAO end === |
| | | } |