| this.waitingLookupRequests=Queues.newArrayBlockingQueue((conf.getMaxLookupRequest() - conf.getConcurrentLookupRequest())); | this.waitingLookupRequests=Queues.newConcurrentLinkedQueue(); | Queues.newArrayBlockingQueue((conf.getMaxLookupRequest() - conf.getConcurrentLookupRequest())) | Queues.newConcurrentLinkedQueue() | pulsar | 3f779a401ab72d39150d3df4958660b58ac0e59c | org.apache.pulsar.client.impl.ClientCnx | | | _1 | waitingLookupRequests |
|---|
| _2 | waitingLookupRequests |
|---|
| | xyz | Queues.newArrayBlockingQueue((conf.getMaxLookupRequest() - conf.getConcurrentLookupRequest())) |
|---|
| - com.google.common.collect.Queues
| | xyz | Queues.newConcurrentLinkedQueue() |
|---|
| AssignedTo | False |