Toggle navigation
Home
org.apache.pulsar.broker.service.persistent.DispatchRateLimiter to java.util.Optional<org.apache.pulsar.broker.service.persistent.DispatchRateLimiter>
No. of Instances - 7
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Add or Remove Method invocation
dispatchRateLimiter.getDispatchRateOnMsg()
to
dispatchRateLimiter.get().getDispatchRateOnMsg()
dispatchRateLimiter.getDispatchRateOnByte()
to
dispatchRateLimiter.get().getDispatchRateOnByte()
dispatchRateLimiter.hasMessageDispatchPermit()
to
dispatchRateLimiter.get().hasMessageDispatchPermit()
dispatchRateLimiter
to
dispatchRateLimiter.get()
dispatchRateLimiter.getDispatchRateOnMsg()
to
dispatchRateLimiter.get().getDispatchRateOnMsg()
dispatchRateLimiter.getDispatchRateOnByte()
to
dispatchRateLimiter.get().getDispatchRateOnByte()
dispatchRateLimiter.hasMessageDispatchPermit()
to
dispatchRateLimiter.get().hasMessageDispatchPermit()
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(); } } )
dispatchRateLimiter
to
dispatchRateLimiter.get()