src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java | ●●●●● 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) {