From 23a391f7552fbc0fbf474604278ecaa0b208564e Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Wed, 03 Feb 2021 11:39:35 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java b/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java index 5eb283a..4f6fb95 100644 --- a/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java +++ b/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java @@ -287,7 +287,6 @@ } } - @Transactional(rollbackFor = Exception.class) public void wholeBomb() { Map<String, WholePriceDataModel> dataModelMap = WholeDataQueue.MAP; if (CollUtil.isEmpty(dataModelMap)) { @@ -339,7 +338,8 @@ continue; } - synchronized (this) { + synchronized(this) { + log.info("็ไปๅฅ็:{}", entry.getKey()); if (entry.getKey() != null) { dataModelMap.remove(entry.getKey()); wholePriceData.setEquity(wholePriceData.getBalance().add(totalProfitOrLoss)); -- Gitblit v1.9.1