From 4e26e834dc8791f67ac3de28d98778fa857fbc53 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Mon, 25 Jan 2021 17:37:14 +0800 Subject: [PATCH] 20210125 --- src/main/java/com/xcong/excoin/rabbit/producer/OrderProducer.java | 12 ++++++++++++ 1 files changed, 12 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/xcong/excoin/rabbit/producer/OrderProducer.java b/src/main/java/com/xcong/excoin/rabbit/producer/OrderProducer.java index d50e96f..8424731 100644 --- a/src/main/java/com/xcong/excoin/rabbit/producer/OrderProducer.java +++ b/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); + } + } -- Gitblit v1.9.1