Skip to content

Commit

Permalink
Increase byte size per sent in throttling test
Browse files Browse the repository at this point in the history
  • Loading branch information
wangjialing committed Nov 24, 2020
1 parent 83f0345 commit 21193ad
Showing 1 changed file with 3 additions and 3 deletions.
Expand Up @@ -210,8 +210,8 @@ public void testMessageRateLimitingReceiveAllMessagesAfterThrottling(Subscriptio
* verify rate-limiting should throttle message-dispatching based on byte-rate
*
* <pre>
* 1. dispatch-byte-rate = 100 bytes/sec
* 2. send 30 msgs : each with 10 byte
* 1. dispatch-byte-rate = 1000 bytes/sec
* 2. send 30 msgs : each with 100 byte
* 3. it should take up to 2 second to receive all messages
* </pre>
*
Expand All @@ -226,7 +226,7 @@ public void testBytesRateLimitingReceiveAllMessagesAfterThrottling(SubscriptionT
final String topicName = "persistent://" + namespace + "/throttlingAll-" + System.nanoTime();
final String subName = "my-subscriber-name-" + subscription;

final int byteRate = 100;
final int byteRate = 1000;
DispatchRate dispatchRate = new DispatchRate(-1, byteRate, 1);
admin.namespaces().createNamespace(namespace, Sets.newHashSet("test"));
admin.namespaces().setSubscriptionDispatchRate(namespace, dispatchRate);
Expand Down

0 comments on commit 21193ad

Please sign in to comment.