Toggle navigation
Home
org.apache.pulsar.broker.service.persistent.SubscribeRateLimiter to java.util.Optional<org.apache.pulsar.broker.service.persistent.SubscribeRateLimiter>
No. of Instances - 2
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Add or Remove Method invocation
subscribeRateLimiter.getSubscribeRate()
to
subscribeRateLimiter.get().getSubscribeRate()
subscribeRateLimiter.getAvailableSubscribeRateLimit(consumer)
to
subscribeRateLimiter.get().getAvailableSubscribeRateLimit(consumer)
subscribeRateLimiter.subscribeAvailable(consumer)
to
subscribeRateLimiter.get().subscribeAvailable(consumer)
subscribeRateLimiter.tryAcquire(consumer)
to
subscribeRateLimiter.get().tryAcquire(consumer)
FutureUtil.waitForAll(futures).thenRun(() -> { ledger.asyncClose(new CloseCallback(){ @Override public void closeComplete( Object ctx){ brokerService.removeTopicFromCache(topic); log.info("[{}] Topic closed",topic); closeFuture.complete(null); } @Override public void closeFailed( ManagedLedgerException exception, Object ctx){ log.error("[{}] Failed to close managed ledger, proceeding anyway.",topic,exception); brokerService.removeTopicFromCache(topic); closeFuture.complete(null); } } ,null); dispatchRateLimiter.close(); subscribeRateLimiter.close(); } )
to
FutureUtil.waitForAll(futures).thenRun(() -> { ledger.asyncClose(new CloseCallback(){ @Override public void closeComplete( Object ctx){ brokerService.removeTopicFromCache(topic); log.info("[{}] Topic closed",topic); closeFuture.complete(null); } @Override public void closeFailed( ManagedLedgerException exception, Object ctx){ log.error("[{}] Failed to close managed ledger, proceeding anyway.",topic,exception); brokerService.removeTopicFromCache(topic); closeFuture.complete(null); } } ,null); if (dispatchRateLimiter.isPresent()) { dispatchRateLimiter.get().close(); } if (subscribeRateLimiter.isPresent()) { subscribeRateLimiter.get().close(); } } )
subscribeRateLimiter
to
subscribeRateLimiter.get()