log.warn(STR0,topic,subscriptionName,consumer,subscribeRateLimiter.getSubscribeRate(),subscribeRateLimiter.getAvailableSubscribeRateLimit(consumer)); | log.warn(STR0,topic,subscriptionName,consumer,subscribeRateLimiter.get().getSubscribeRate(),subscribeRateLimiter.get().getAvailableSubscribeRateLimit(consumer)); | subscribeRateLimiter.getAvailableSubscribeRateLimit(consumer) | subscribeRateLimiter.get().getSubscribeRate() | pulsar | 2cca8ce83667fccde428db536a1446eef2203f8e | org.apache.pulsar.broker.service.persistent.PersistentTopic | | _1 | subscribeRateLimiter |
---|
_2 | subscribeRateLimiter |
---|
| TCIVar | subscribeRateLimiter |
---|
| | TCIVar | subscribeRateLimiter |
---|
| Uses | False |