src/main/java/com/xcong/excoin/rabbit/producer/OrderProducer.java
@@ -149,4 +149,16 @@ rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_A, RabbitMqConfig.ROUTINGKEY_LIMIT_CLOSE, content, correlationData); } /** * 发送全仓爆仓 * * @param content */ public void sendWholeBomb(String content) { CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); log.info("发送全仓爆仓消息:{} == pid:{}", content, correlationData.getId()); rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_A, RabbitMqConfig.ROUTINGKEY_WHOLE_BOMB, content, correlationData); } }