src/main/java/com/xcong/excoin/rabbit/consumer/WebsocketPriceConsumer.java
@@ -159,4 +159,15 @@ List<OrderModel> list = JSONArray.parseArray(content, OrderModel.class); orderService.entrustCloseOrder(list); } /** * 全仓爆仓 * * @param message * @param channel */ @RabbitListener(queues = RabbitMqConfig.QUEUE_WHOLE_BOMB) public void onMessageWholeBomb(Message message, Channel channel) { } }