Skip to content

Commit

Permalink
[cleanup][test] Delete unnecessary variables in SubscriptionMessageDi…
Browse files Browse the repository at this point in the history
…spatchThrottlingTest (#17702)
  • Loading branch information
guan46 authored Sep 20, 2022
1 parent 3cd129b commit 311ca90
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -567,9 +567,6 @@ public void testBrokerBytesRateLimitingReceiveAllMessagesAfterThrottling(Subscri
Producer<byte[]> producer1 = pulsarClient.newProducer().topic(topicName1).create();
Producer<byte[]> producer2 = pulsarClient.newProducer().topic(topicName2).create();

boolean isMessageRateUpdate = false;
DispatchRateLimiter dispatchRateLimiter;

Awaitility.await().atMost(Duration.ofMillis(500)).untilAsserted(() -> {
DispatchRateLimiter rateLimiter = pulsar.getBrokerService().getBrokerDispatchRateLimiter();
Assert.assertTrue(rateLimiter != null
Expand Down

0 comments on commit 311ca90

Please sign in to comment.