log.debug(STR0,name,dispatchRateLimiter.getDispatchRateOnMsg(),dispatchRateLimiter.getDispatchRateOnByte(),MESSAGE_RATE_BACKOFF_MS); | log.debug(STR0,name,dispatchRateLimiter.get().getDispatchRateOnMsg(),dispatchRateLimiter.get().getDispatchRateOnByte(),MESSAGE_RATE_BACKOFF_MS); | dispatchRateLimiter.getDispatchRateOnMsg() | dispatchRateLimiter.get().getDispatchRateOnByte() | pulsar | 2cca8ce83667fccde428db536a1446eef2203f8e | org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer | | _1 | dispatchRateLimiter |
---|
_2 | dispatchRateLimiter |
---|
| TCIVar | dispatchRateLimiter |
---|
| | TCIVar | dispatchRateLimiter |
---|
| Uses | True |
log.debug(STR0,name,dispatchRateLimiter.getDispatchRateOnMsg(),dispatchRateLimiter.getDispatchRateOnByte(),MESSAGE_RATE_BACKOFF_MS); | log.debug(STR0,name,dispatchRateLimiter.get().getDispatchRateOnMsg(),dispatchRateLimiter.get().getDispatchRateOnByte(),MESSAGE_RATE_BACKOFF_MS); | dispatchRateLimiter.getDispatchRateOnMsg() | dispatchRateLimiter.get().getDispatchRateOnByte() | pulsar | 2cca8ce83667fccde428db536a1446eef2203f8e | org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers | | _1 | dispatchRateLimiter |
---|
_2 | dispatchRateLimiter |
---|
| TCIVar | dispatchRateLimiter |
---|
| | TCIVar | dispatchRateLimiter |
---|
| Uses | True |