|
Change Variable Type consumer3 : Consumer<byte[]> to consumer3 : Consumer<Integer> in method public testOrderingKeyWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type iterator : Iterator<Map.Entry<byte[],List<Entry>>> to iterator : Iterator<Map.Entry<Integer,List<Entry>>> in method protected sendMessagesToConsumers(readType ReadType, entries List<Entry>) : void in class org.apache.pulsar.broker.service.persistent.PersistentStickyKeyDispatcherMultipleConsumers |
From |
To |
|
Change Variable Type producer : Producer<byte[]> to producer : Producer<Integer> in method public testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type producer : Producer<byte[]> to producer : Producer<Integer> in method public testNonKeySendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer2 : Consumer<byte[]> to consumer2 : Consumer<Integer> in method public testSendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer3 : Consumer<byte[]> to consumer3 : Consumer<Integer> in method public testNonKeySendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type producer : Producer<byte[]> to producer : Producer<Integer> in method public testOrderingKeyWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer1 : Consumer<byte[]> to consumer1 : Consumer<Integer> in method public testSendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type producer : Producer<byte[]> to producer : Producer<Integer> in method public testSendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type entriesWithSameKey : Map.Entry<byte[],List<Entry>> to entriesWithSameKey : Map.Entry<Integer,List<Entry>> in method protected sendMessagesToConsumers(readType ReadType, entries List<Entry>) : void in class org.apache.pulsar.broker.service.persistent.PersistentStickyKeyDispatcherMultipleConsumers |
From |
To |
|
Change Variable Type consumer1 : Consumer<byte[]> to consumer1 : Consumer<Integer> in method public testNonKeySendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer1 : Consumer<byte[]> to consumer1 : Consumer<Integer> in method public testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer2 : Consumer<byte[]> to consumer2 : Consumer<Integer> in method public testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer3 : Consumer<byte[]> to consumer3 : Consumer<Integer> in method public testConsumerCrashSendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer2 : Consumer<byte[]> to consumer2 : Consumer<Integer> in method public testNonKeySendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer1 : Consumer<byte[]> to consumer1 : Consumer<Integer> in method public testOrderingKeyWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer3 : Consumer<byte[]> to consumer3 : Consumer<Integer> in method public testSendAndReceiveWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |
|
Change Variable Type consumer2 : Consumer<byte[]> to consumer2 : Consumer<Integer> in method public testOrderingKeyWithHashRangeStickyKeyConsumerSelector() : void in class org.apache.pulsar.client.api.KeySharedSubscriptionTest |
From |
To |