| | |
| | | |
| | | public static final String ROUTINGKEY_FOLLOW_ORDER = "ROUTINGKEY_FOLLOW_ORDER"; |
| | | |
| | | // 跟单调整保证金 |
| | | public static final String QUEUE_FOLLOW_CHANGE_BOND = "QUEUE_FOLLOW_CHANGE_BOND"; |
| | | |
| | | public static final String ROUTINGKEY_FOLLOW_CHANGE_BOND = "ROUTINGKEY_FOLLOW_CHANGE_BOND"; |
| | | |
| | | // 开多止盈路由键 |
| | | public static final String ROUTINGKEY_MOREPRO = "ROUTINGKEY_MOREPRO"; |
| | | // 开空止盈路由 |
| | |
| | | } |
| | | |
| | | @Bean |
| | | public Queue queueFollowChangeBond() { |
| | | return new Queue(QUEUE_FOLLOW_CHANGE_BOND, true); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding bindingFollowChangeBond() { |
| | | return BindingBuilder.bind(queueFollowChangeBond()).to(orderExchange()).with(ROUTINGKEY_FOLLOW_CHANGE_BOND); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding bindingFollowOrder() { |
| | | return BindingBuilder.bind(queueFollowOrder()).to(orderExchange()).with(RabbitMqConfig.ROUTINGKEY_FOLLOW_ORDER); |
| | | } |