semaphore.release(isBatchMessagingEnabled() ? op.numMessagesInBatch : 1); | semaphore.get().release(isBatchMessagingEnabled() ? op.numMessagesInBatch : 1); | semaphore.release(isBatchMessagingEnabled() ? op.numMessagesInBatch : 1) | semaphore.get().release(isBatchMessagingEnabled() ? op.numMessagesInBatch : 1) | pulsar | 2f47c32554998f2739f741b1c29e59812c5be955 | org.apache.pulsar.client.impl.ProducerImpl | | | TCIVar | semaphore |
---|
v1 | isBatchMessagingEnabled() ? op.numMessagesInBatch : 1 |
---|
| | TCIVar | semaphore |
---|
v1 | isBatchMessagingEnabled() ? op.numMessagesInBatch : 1 |
---|
| Uses | True |