|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testBlockUnackedConsumerRedeliverySpecificMessagesCloseConsumerWhileProduce() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type consumerImpl : ConsumerImpl to consumerImpl : ConsumerImpl<byte[]> in method public testConcurrentConsumerReceiveWhileReconnect(batchMessageDelayMs int) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testDeactivatingBacklogConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testShouldNotBlockConsumerIfRedeliverBeforeReceive() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public main(args String[]) : void in class org.apache.pulsar.storm.example.StormExample |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testConcurrentConsumerReceiveWhileReconnect(batchMessageDelayMs int) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testConsumerBlockingWithUnAckedMessagesMultipleIteration() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages1 : List<Message> to messages1 : List<Message<byte[]>> in method public testRedeliveryFailOverConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testMutlipleSharedConsumerBlockingWithUnAckedMessages() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testActiveAndInActiveConsumerEntryCacheBehavior() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages1 : List<Message> to messages1 : List<Message<byte[]>> in method public testBlockUnackedConsumerRedeliverySpecificMessagesProduceWithPause() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testECDSAEncryption() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type consumer : Consumer to consumer : Consumer<byte[]> in method public testSubscribeRate() : void in class org.apache.pulsar.broker.admin.NamespacesTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<String> in method public testSyncProducerAndConsumer(batchMessageDelayMs int) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method public start() : void in class org.apache.pulsar.testclient.LoadSimulationClient.TradeUnit |
From |
To |
|
Change Variable Type consumer : Consumer to consumer : Consumer<byte[]> in method public start() : void in class org.apache.pulsar.testclient.LoadSimulationClient.TradeUnit |
From |
To |
|
Change Variable Type messages : List<Message> to messages : List<Message<byte[]>> in method public testMutlipleSharedConsumerBlockingWithUnAckedMessages() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages : List<Message> to messages : List<Message<byte[]>> in method public testSharedSamePriorityConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages : List<Message> to messages : List<Message<byte[]>> in method public testUnackedBlockAtBatch(batchMessageDelayMs int) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testEnabledChecksumClient() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testSendTimeout(batchMessageDelayMs int) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type consumerMsgSet1 : Set<Message> to consumerMsgSet1 : Set<Message<byte[]>> in method public testSharedConsumerAckDifferentConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type consumerMsgSet2 : Set<Message> to consumerMsgSet2 : Set<Message<byte[]>> in method public testSharedConsumerAckDifferentConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages1 : List<Message> to messages1 : List<Message<byte[]>> in method public testBlockUnackedConsumerRedeliverySpecificMessagesCloseConsumerWhileProduce() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testSharedConsumerAckDifferentConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages : List<Message> to messages : List<Message<byte[]>> in method public testConsumerBlockingWithUnAckedMessages() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testSharedSamePriorityConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testAsyncProducerAndAsyncAck(batchMessageDelayMs int) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testUnackedBlockAtBatch(batchMessageDelayMs int) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<String> in method public testEncryptionFailure() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testConsumerBlockingWithUnAckedMessages() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testRedeliveryFailOverConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages : List<Message> to messages : List<Message<byte[]>> in method public testConsumerBlockingWithUnAckedMessagesMultipleIteration() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages : List<Message> to messages : List<Message<byte[]>> in method public testUnackBlockRedeliverMessages() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message<byte[]> to msgBuilder : TypedMessageBuilder<byte[]> in method public execute(input Tuple) : void in class org.apache.pulsar.storm.PulsarBolt |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testBlockUnackedConsumerRedeliverySpecificMessagesProduceWithPause() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testUnackBlockRedeliverMessages() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testBlockUnackConsumerAckByDifferentConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type messages : List<Message> to messages : List<Message<byte[]>> in method public testBlockUnackConsumerAckByDifferentConsumer() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type future : CompletableFuture<Message> to future : CompletableFuture<Message<byte[]>> in method private receiveAsync(consumer Consumer<byte[]>, totalMessage int, currentMessage int, latch CountDownLatch, consumeMsg Set<String>, executor ExecutorService) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testRSAEncryption() : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public testBackoffAndReconnect(batchMessageDelayMs int) : void in class org.apache.pulsar.client.api.v1.V1_ProducerConsumerTest |
From |
To |