| | |
|---|
| | | 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) { |
|---|
| | | log.info("#----->{}#", correlationData); |
|---|
| | | //log.info("#----->{}#", correlationData); |
|---|
| | | if (ack) { |
|---|
| | | log.info("success"); |
|---|
| | | // log.info("success"); |
|---|
| | | } else { |
|---|
| | | log.info("--->{}", cause); |
|---|
| | | } |
|---|
