Helius
2021-02-03 23a391f7552fbc0fbf474604278ecaa0b208564e
modify
1 files modified
5 ■■■■■ changed files
src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java 5 ●●●●● patch | view | raw | blame | history
src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
@@ -287,8 +287,7 @@
        }
    }
    @Transactional(rollbackFor = Exception.class)
    public synchronized void wholeBomb() {
    public void wholeBomb() {
        Map<String, WholePriceDataModel> dataModelMap = WholeDataQueue.MAP;
        if (CollUtil.isEmpty(dataModelMap)) {
            return;
@@ -339,6 +338,7 @@
                    continue;
                }
                synchronized(this) {
                log.info("็ˆ†ไป“ๅ•ฅ็š„:{}", entry.getKey());
                if (entry.getKey() != null) {
                    dataModelMap.remove(entry.getKey());
@@ -352,6 +352,7 @@
            }
        }
    }
    }
    public void wholeBomb(String symbol, String price) {