| | |
| | | |
| | | public static final String ROUTING_KEY_ROC_ORDER_COMPLETE = "roc-order-routingKey-complete"; |
| | | |
| | | public static final String QUEUE_TRC20_BLOCK = "QUEUE_TRC20_BLOCK"; |
| | | public static final String ROUTING_TRC20_BLOCK = "ROUTING_TRC20_BLOCK"; |
| | | |
| | | @Resource |
| | | private ConnectionFactory connectionFactory; |
| | |
| | | return BindingBuilder.bind(usdtAddressQueue()).to(usdtAddressExchange()).with(ROUTING_KEY_USDT_ADDRESS); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue trc20Queue() { |
| | | return new Queue(QUEUE_TRC20_BLOCK); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding trc20Binding() { |
| | | return BindingBuilder.bind(trc20Queue()).to(defaultExchange()).with(ROUTING_TRC20_BLOCK); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 交换器A 可以继续添加交换器B C |