back_recharge
parent
a2504adc4c
commit
d3dc23884e
|
@ -19,7 +19,7 @@ public class ConcurrentDataMessage {
|
|||
Map<String, Map<String, MongoUpdateCache.UpdateRequest>> take = ConcurrentDataMessage.dataQueue.take();
|
||||
// myMongoTemplate.concurrentDataUpdate(take);
|
||||
myMongoTemplate.updateMongoData(take);
|
||||
// }
|
||||
}
|
||||
|
||||
public static void main(String[] args) throws InterruptedException {
|
||||
BlockingQueue<Map<String, String>> dataQueueTest = new BlockingUniqueQueue<>();
|
||||
|
|
Loading…
Reference in New Issue