| | |
|---|
| | | rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_ROC_ORDER_SUBMIT, RabbitMqConfig.ROUTING_KEY_ROC_ORDER_SUBMIT, content, correlationData); |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void sendCancelMsg(String content) { |
|---|
| | | CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID()); |
|---|
| | | rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_ROC_ORDER_CANCEL, RabbitMqConfig.ROUTING_KEY_ROC_ORDER_CANCEL, content, correlationData); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void confirm(CorrelationData correlationData, boolean ack, String cause) { |
|---|
