| | |
| | | rabbitTemplate.setConfirmCallback(this); |
| | | } |
| | | |
| | | public void sendMemberCoinInside(Long withdrawId) { |
| | | log.info("发送用户内部转账的消息:{}", withdrawId); |
| | | CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); |
| | | rabbitTemplate.convertAndSend(RabbitMqConfig.MEMBER_COIN_INSIDE_EXCHANGE, RabbitMqConfig.MEMBER_COIN_INSIDE__ROUTE_KEY, withdrawId, correlationData); |
| | | } |
| | | |
| | | public void sendOnHookEnd(Long orderId) { |
| | | log.info("发送用户结束挂机的消息:{}", orderId); |
| | | CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); |