|
Change Variable Type pc : PartitionedConsumerImpl<byte[]> to pc : MultiTopicsConsumerImpl<byte[]> in method private getUnackedMessagesCountInPartitionedConsumer(c Consumer<byte[]>) : long in class org.apache.pulsar.client.impl.PerMessageUnAcknowledgedRedeliveryTest |
From |
To |
|
Change Variable Type consumer1 : PatternTopicsConsumerImpl<byte[]> to consumer1 : PatternMultiTopicsConsumerImpl<byte[]> in method public testStartEmptyPatternConsumer() : void in class org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest |
From |
To |
|
Change Variable Type messageId : MessageIdImpl to messageId : MessageId in method private removeExpiredMessagesFromQueue(messageIds Set<MessageId>) : void in class org.apache.pulsar.client.impl.MultiTopicsConsumerImpl |
From |
To |
|
Change Variable Type consumer1 : PatternTopicsConsumerImpl<byte[]> to consumer1 : PatternMultiTopicsConsumerImpl<byte[]> in method public testAutoSubscribePatternConsumer() : void in class org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest |
From |
To |
|
Change Variable Type consumer1 : PatternTopicsConsumerImpl<byte[]> to consumer1 : PatternMultiTopicsConsumerImpl<byte[]> in method public testAutoUnbubscribePatternConsumer() : void in class org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest |
From |
To |