| | |
| | | |
| | | public static final String ROUTING_KEY_ROC_ORDER_CANCEL = "roc-order-routingKey-cancel"; |
| | | |
| | | public static final String EXCHANGE_ROC_ORDER_COMPLETE = "roc-exchange-order-complete"; |
| | | |
| | | public static final String QUEUE_ROC_ORDER_COMPLETE = "roc-order-queue-complete"; |
| | | |
| | | public static final String ROUTING_KEY_ROC_ORDER_COMPLETE = "roc-order-routingKey-complete"; |
| | | |
| | | |
| | | @Resource |
| | | private ConnectionFactory connectionFactory; |
| | |
| | | public Binding bindingCancelOrder() { |
| | | return BindingBuilder.bind(ordereCancelQueue()).to(orderCancelExchange()).with(ROUTING_KEY_ROC_ORDER_CANCEL); |
| | | } |
| | | // 交易订单 |
| | | @Bean |
| | | public DirectExchange orderCompleteExchange() { |
| | | return new DirectExchange(EXCHANGE_ROC_ORDER_COMPLETE); |
| | | } |
| | | |
| | | |
| | | @Bean |
| | | public Queue ordereCompleteQueue() { |
| | | return new Queue(QUEUE_ROC_ORDER_COMPLETE, true); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding bindingCompleteOrder() { |
| | | return BindingBuilder.bind(ordereCompleteQueue()).to(orderCompleteExchange()).with(ROUTING_KEY_ROC_ORDER_COMPLETE); |
| | | } |
| | | |
| | | |
| | | @Bean |