| | |
| | | public static final String ROUTING_KEE_XCH_USDT_PRIFIT = "ROUTING_KEE_XCH_USDT_PRIFIT"; |
| | | public static final String EXCHANGE_XCH = "EXCHANGE_XCH"; |
| | | |
| | | public static final String QUEUE_XCH_AUTO_AGENT = "QUEUE_XCH_AUTO_AGENT"; |
| | | public static final String ROUTING_KEY_XCH_AUTO_AGENT = "ROUTING_KEY_XCH_AUTO_AGENT"; |
| | | |
| | | |
| | | /** |
| | | * 撮合交易 |
| | |
| | | } |
| | | |
| | | @Bean |
| | | public Queue xchAutoAgentQueue() { |
| | | return new Queue(QUEUE_XCH_AUTO_AGENT, true); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding xchAutoAgentBinding() { |
| | | return BindingBuilder.bind(xchAutoAgentQueue()).to(xchExchange()).with(ROUTING_KEY_XCH_AUTO_AGENT); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue testQueue() { |
| | | return new Queue(QUEUE_TEST, true); |
| | | } |