src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
@@ -37,6 +37,7 @@ // 可以操作 System.out.println("当前价格:" + price + "---正序---" + "队列价格:" + b.getValue().toPlainString() + " time:" + new Date()); while (queue.peek() != null && queue.peek().compareTo(now) <= 0) { log.info("------->"); // 可以发送消息操作 list.add(queue.remove()); } @@ -92,6 +93,7 @@ } } log.info("------>{}", JSONObject.toJSONString(orderModelList)); if (CollectionUtils.isEmpty(orderModelList)) { return; }