|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method private singleTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Parameter Type message : MessageImpl to message : Message<T> in method package notifyPendingReceivedCallback(message Message<T>, exception Exception) : void in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Parameter Type message : byte[] to message : T in method public send(message T) : MessageId in class org.apache.pulsar.client.api.Producer |
From |
To |
|
Change Parameter Type producerCreatedFuture : CompletableFuture<Producer> to producerCreatedFuture : CompletableFuture<Producer<T>> in method public ProducerImpl(client PulsarClientImpl, topic String, conf ProducerConfigurationData, producerCreatedFuture CompletableFuture<Producer<T>>, partitionIndex int, schema Schema<T>) in class org.apache.pulsar.client.impl.ProducerImpl |
From |
To |
|
Change Parameter Type producerCreatedFuture : CompletableFuture<Producer> to producerCreatedFuture : CompletableFuture<Producer<T>> in method protected ProducerBase(client PulsarClientImpl, topic String, conf ProducerConfigurationData, producerCreatedFuture CompletableFuture<Producer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ProducerBase |
From |
To |
|
Change Parameter Type producerCreatedFuture : CompletableFuture<Producer> to producerCreatedFuture : CompletableFuture<Producer<T>> in method public PartitionedProducerImpl(client PulsarClientImpl, topic String, conf ProducerConfigurationData, numPartitions int, producerCreatedFuture CompletableFuture<Producer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.PartitionedProducerImpl |
From |
To |
|
Change Parameter Type consumer : ConsumerImpl to consumer : ConsumerImpl<T> in method private receiveMessageFromConsumer(consumer ConsumerImpl<T>) : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Parameter Type subscribeFuture : CompletableFuture<Consumer> to subscribeFuture : CompletableFuture<Consumer<T>> in method public PatternTopicsConsumerImpl(topicsPattern Pattern, client PulsarClientImpl, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.PatternTopicsConsumerImpl |
From |
To |
|
Change Parameter Type message : Message to message : Message<T> in method public abstract sendAsync(message Message<T>) : CompletableFuture<MessageId> in class org.apache.pulsar.client.impl.ProducerBase |
From |
To |
|
Change Parameter Type readerListener : ReaderListener to readerListener : ReaderListener<byte[]> in method public setReaderListener(readerListener ReaderListener<byte[]>) : ReaderConfiguration in class org.apache.pulsar.client.api.ReaderConfiguration |
From |
To |
|
Change Parameter Type message : Message to message : Message<T> in method public sendAsync(message Message<T>) : CompletableFuture<MessageId> in class org.apache.pulsar.client.impl.PartitionedProducerImpl |
From |
To |
|
Change Parameter Type subscribeFuture : CompletableFuture<Consumer> to subscribeFuture : CompletableFuture<Consumer<T>> in method package TopicsConsumerImpl(client PulsarClientImpl, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method package ConsumerImpl(client PulsarClientImpl, topic String, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, partitionIndex int, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Parameter Type message : Message to message : Message<T> in method public send(message Message<T>) : MessageId in class org.apache.pulsar.client.api.Producer |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method private patternTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Parameter Type consumer : ConsumerImpl to consumer : ConsumerImpl<T> in method private receiveMessageFromConsumer(consumer ConsumerImpl<T>) : void in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Parameter Type producer : Producer to producer : Producer<byte[]> in method protected readEntries(producer Producer<byte[]>) : void in class org.apache.pulsar.broker.service.persistent.PersistentReplicator |
From |
To |
|
Change Parameter Type producer : Producer to producer : Producer<byte[]> in method protected abstract readEntries(producer Producer<byte[]>) : void in class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Change Parameter Type message : Message to message : Message<T> in method public sendAsync(message Message<T>) : CompletableFuture<MessageId> in class org.apache.pulsar.client.api.Producer |
From |
To |
|
Change Parameter Type c : Consumer to c : Consumer<byte[]> in method private getUnackedMessagesCountInPartitionedConsumer(c Consumer<byte[]>) : long in class org.apache.pulsar.client.impl.PerMessageUnAcknowledgedRedeliveryTest |
From |
To |
|
Change Parameter Type conf : ReaderConfigurationData to conf : ReaderConfigurationData<T> in method public createReaderAsync(conf ReaderConfigurationData<T>, schema Schema<T>) : CompletableFuture<Reader<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Parameter Type message : byte[] to message : T in method public sendAsync(message T) : CompletableFuture<MessageId> in class org.apache.pulsar.client.impl.ProducerBase |
From |
To |
|
Change Parameter Type producer : Producer to producer : Producer<byte[]> in method protected readEntries(producer Producer<byte[]>) : void in class org.apache.pulsar.broker.service.nonpersistent.NonPersistentReplicator |
From |
To |
|
Change Parameter Type subscribeFuture : CompletableFuture<Consumer> to subscribeFuture : CompletableFuture<Consumer<T>> in method package ConsumerImpl(client PulsarClientImpl, topic String, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, partitionIndex int, subscribeFuture CompletableFuture<Consumer<T>>, subscriptionMode SubscriptionMode, startMessageId MessageId, schema Schema<T>) in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Parameter Type subscribeFuture : CompletableFuture<Consumer> to subscribeFuture : CompletableFuture<Consumer<T>> in method protected ConsumerBase(client PulsarClientImpl, topic String, conf ConsumerConfigurationData<T>, receiverQueueSize int, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Parameter Type message : Message to message : Message<T> in method package messageReceived(message Message<T>) : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Parameter Type message : Message to message : Message<T> in method public send(message Message<T>) : MessageId in class org.apache.pulsar.client.impl.ProducerBase |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method package ConsumerImpl(client PulsarClientImpl, topic String, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, partitionIndex int, subscribeFuture CompletableFuture<Consumer<T>>, subscriptionMode SubscriptionMode, startMessageId MessageId, schema Schema<T>) in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method protected ConsumerBase(client PulsarClientImpl, topic String, conf ConsumerConfigurationData<T>, receiverQueueSize int, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Parameter Type messageListener : MessageListener to messageListener : MessageListener<T> in method public messageListener(messageListener MessageListener<T>) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Parameter Type message : byte[] to message : T in method public sendAsync(message T) : CompletableFuture<MessageId> in class org.apache.pulsar.client.api.Producer |
From |
To |
|
Change Parameter Type subscribeFuture : CompletableFuture<Consumer> to subscribeFuture : CompletableFuture<Consumer<T>> in method package ConsumerImpl(client PulsarClientImpl, topic String, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, partitionIndex int, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Parameter Type messageListener : MessageListener to messageListener : MessageListener<T> in method public messageListener(messageListener MessageListener<T>) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Parameter Type subscribeFuture : CompletableFuture<Consumer> to subscribeFuture : CompletableFuture<Consumer<T>> in method package PartitionedConsumerImpl(client PulsarClientImpl, conf ConsumerConfigurationData<T>, numPartitions int, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method private multiTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Parameter Type readerConfiguration : ReaderConfigurationData to readerConfiguration : ReaderConfigurationData<T> in method public ReaderImpl(client PulsarClientImpl, readerConfiguration ReaderConfigurationData<T>, listenerExecutor ExecutorService, consumerFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method private ConsumerBuilderImpl(client PulsarClientImpl, conf ConsumerConfigurationData<T>, schema Schema<T>) in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method public subscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method public PatternTopicsConsumerImpl(topicsPattern Pattern, client PulsarClientImpl, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.PatternTopicsConsumerImpl |
From |
To |
|
Change Parameter Type consumerFuture : CompletableFuture<Consumer> to consumerFuture : CompletableFuture<Consumer<byte[]>> in method public RawReaderImpl(client PulsarClientImpl, topic String, subscription String, consumerFuture CompletableFuture<Consumer<byte[]>>) in class org.apache.pulsar.client.impl.RawReaderImpl |
From |
To |
|
Change Parameter Type consumerFuture : CompletableFuture<Consumer> to consumerFuture : CompletableFuture<Consumer<T>> in method public ReaderImpl(client PulsarClientImpl, readerConfiguration ReaderConfigurationData<T>, listenerExecutor ExecutorService, consumerFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method package TopicsConsumerImpl(client PulsarClientImpl, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Parameter Type consumerFuture : CompletableFuture<Consumer> to consumerFuture : CompletableFuture<Consumer<byte[]>> in method package RawConsumerImpl(client PulsarClientImpl, conf ConsumerConfigurationData, consumerFuture CompletableFuture<Consumer<byte[]>>) in class org.apache.pulsar.client.impl.RawReaderImpl.RawConsumerImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfigurationData to conf : ConsumerConfigurationData<T> in method package PartitionedConsumerImpl(client PulsarClientImpl, conf ConsumerConfigurationData<T>, numPartitions int, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Parameter Type message : byte[] to message : T in method public send(message T) : MessageId in class org.apache.pulsar.client.impl.ProducerBase |
From |
To |
|
Change Return Type CompletableFuture<Reader> to CompletableFuture<Reader<T>> in method public createAsync() : CompletableFuture<Reader<T>> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public messageListener(messageListener MessageListener<T>) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public topic(topicName String) : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public consumerName(consumerName String) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public producerName(producerName String) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type CompletableFuture<Producer> to CompletableFuture<Producer<byte[]>> in method public createProducerAsync(topic String) : CompletableFuture<Producer<byte[]>> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type Reader to Reader<T> in method public create() : Reader<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public maxTotalReceiverQueueSizeAcrossPartitions(maxTotalReceiverQueueSizeAcrossPartitions int) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public hashingScheme(hashingScheme HashingScheme) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<byte[]> in method public newConsumer() : ConsumerBuilder<byte[]> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<byte[]> in method public newProducer() : ProducerBuilder<byte[]> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setProperty(name String, value String) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public enableBatching(enableBatching boolean) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public cryptoFailureAction(action ConsumerCryptoFailureAction) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public compressionType(compressionType CompressionType) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type Reader to Reader<T> in method public create() : Reader<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public blockIfQueueFull(blockIfQueueFull boolean) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type Message to Message<T> in method protected internalReceive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public cryptoFailureAction(action ConsumerCryptoFailureAction) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type CompletableFuture<Message> to CompletableFuture<Message<T>> in method public readNextAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public batchingMaxPublishDelay(batchDelay long, timeUnit TimeUnit) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setContent(data byte[], offset int, length int) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public createProducer(topic String, conf ProducerConfiguration) : Producer<byte[]> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setKey(key String) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type Consumer to Consumer<byte[]> in method public subscribe(topic String, subscription String) : Consumer<byte[]> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public disableReplication() : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type CompletableFuture<Message> to CompletableFuture<Message<T>> in method public receiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.api.Consumer |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public clone() : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public clone() : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type CompletableFuture<Producer> to CompletableFuture<Producer<T>> in method public createAsync() : CompletableFuture<Producer<T>> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type Reader to Reader<byte[]> in method public createReader(topic String, startMessageId MessageId, conf ReaderConfiguration) : Reader<byte[]> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type CompletableFuture<Producer> to CompletableFuture<Producer<T>> in method public producerCreatedFuture() : CompletableFuture<Producer<T>> in class org.apache.pulsar.client.impl.ProducerBase |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public disableReplication() : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public sendTimeout(sendTimeout int, unit TimeUnit) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setKey(key String) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public addEncryptionKey(key String) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public batchingMaxPublishDelay(batchDelay long, timeUnit TimeUnit) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ConsumerConfigurationData to ConsumerConfigurationData<T> in method private getInternalConsumerConfig() : ConsumerConfigurationData<T> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public cryptoFailureAction(action ConsumerCryptoFailureAction) : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public topics(topicNames List<String>) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type Consumer to Consumer<byte[]> in method public subscribe(topic String, subscription String) : Consumer<byte[]> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public topic(topicName String) : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public messageRoutingMode(messageRouteMode MessageRoutingMode) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Reader> to CompletableFuture<Reader<byte[]>> in method public createReaderAsync(topic String, startMessageId MessageId, conf ReaderConfiguration) : CompletableFuture<Reader<byte[]>> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public startMessageId(startMessageId MessageId) : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public blockIfQueueFull(blockIfQueueFull boolean) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public clone() : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public clone() : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method public receive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public startMessageId(startMessageId MessageId) : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type Message to Message<T> in method private fetchSingleMessageFromBroker() : Message<T> in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Return Type CompletableFuture<Producer> to CompletableFuture<Producer<byte[]>> in method public createProducerAsync(topic String, conf ProducerConfiguration) : CompletableFuture<Producer<byte[]>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<T>> in method public subscribeAsync() : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setProperty(name String, value String) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<byte[]>> in method public subscribeAsync(topic String, subscription String, conf ConsumerConfiguration) : CompletableFuture<Consumer<byte[]>> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public priorityLevel(priorityLevel int) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public ackTimeout(ackTimeout long, timeUnit TimeUnit) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setReplicationClusters(clusters List<String>) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public topics(topicNames List<String>) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type Message to Message<T> in method protected internalReceive() : Message<T> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public properties(properties Map<String,String>) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public properties(properties Map<String,String>) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type List<ConsumerImpl> to List<ConsumerImpl<T>> in method package getConsumers() : List<ConsumerImpl<T>> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public subscriptionName(subscriptionName String) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<byte[]> in method public newReader() : ReaderBuilder<byte[]> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setEventTime(timestamp long) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setReplicationClusters(clusters List<String>) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<byte[]>> in method public subscribeAsync(topic String, subscription String, conf ConsumerConfiguration) : CompletableFuture<Consumer<byte[]>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type Message to Message<T> in method protected internalReceive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public readerName(readerName String) : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setSequenceId(sequenceId long) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method public receive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.api.Consumer |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public consumerName(consumerName String) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public producerName(producerName String) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method protected internalReceive() : Message<T> in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public sendTimeout(sendTimeout int, unit TimeUnit) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Reader> to CompletableFuture<Reader<T>> in method public createReaderAsync(conf ReaderConfigurationData<T>, schema Schema<T>) : CompletableFuture<Reader<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<T>> in method private singleTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type Consumer to Consumer<T> in method public subscribe() : Consumer<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method public readNext(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public priorityLevel(priorityLevel int) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public messageRouter(messageRouter MessageRouter) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public compressionType(compressionType CompressionType) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public receiverQueueSize(receiverQueueSize int) : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type CompletableFuture<Message> to CompletableFuture<Message<T>> in method protected abstract internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<byte[]>> in method public subscribeAsync(topic String, subscription String) : CompletableFuture<Consumer<byte[]>> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public property(key String, value String) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public property(key String, value String) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public messageRoutingMode(messageRoutingMode MessageRoutingMode) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type CompletableFuture<Producer> to CompletableFuture<Producer<byte[]>> in method public createProducerAsync(topic String) : CompletableFuture<Producer<byte[]>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public createProducer(topic String) : Producer<byte[]> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type Consumer to Consumer<T> in method public subscribe() : Consumer<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setContent(data byte[]) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type Consumer to Consumer<byte[]> in method public subscribe(topic String, subscription String, conf ConsumerConfiguration) : Consumer<byte[]> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type MessageImpl to MessageImpl<byte[]> in method package create(msgMetadataBuilder MessageMetadata.Builder, payload ByteBuffer) : MessageImpl<byte[]> in class org.apache.pulsar.client.impl.MessageImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public maxPendingMessagesAcrossPartitions(maxPendingMessagesAcrossPartitions int) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<T>> in method private multiTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type Reader to Reader<byte[]> in method public createReader(topic String, startMessageId MessageId, conf ReaderConfiguration) : Reader<byte[]> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public receiverQueueSize(receiverQueueSize int) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type CompletableFuture<Producer> to CompletableFuture<Producer<byte[]>> in method public createProducerAsync(conf ProducerConfigurationData) : CompletableFuture<Producer<byte[]>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public topic(topicNames String...) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public topic(topicName String) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public readerListener(readerListener ReaderListener) : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public subscriptionName(subscriptionName String) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ReaderConfigurationData to ReaderConfigurationData<T> in method public clone() : ReaderConfigurationData<T> in class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public cryptoFailureAction(action ProducerCryptoFailureAction) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method public readNext(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.api.Reader |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public createProducer(topic String, conf ProducerConfiguration) : Producer<byte[]> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public subscriptionRolePrefix(subscriptionRolePrefix String) : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public maxPendingMessages(maxPendingMessages int) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<byte[]>> in method public subscribeAsync(topic String, subscription String) : CompletableFuture<Consumer<byte[]>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type CompletableFuture<Producer> to CompletableFuture<Producer<T>> in method public createAsync() : CompletableFuture<Producer<T>> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public cryptoFailureAction(action ProducerCryptoFailureAction) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public initialSequenceId(initialSequenceId long) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method protected internalReceive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public subscriptionRolePrefix(subscriptionRolePrefix String) : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type Message to Message<T> in method public readNext() : Message<T> in class org.apache.pulsar.client.api.Reader |
From |
To |
|
Change Return Type Message to Message<byte[]> in method public toMessage(tuple Tuple) : Message<byte[]> in class org.apache.pulsar.storm.TupleToMessageMapper |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public maxPendingMessagesAcrossPartitions(maxPendingMessagesAcrossPartitions int) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<byte[]> in method public create() : MessageBuilder<byte[]> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setContent(data byte[], offet int, length int) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method public receive() : Message<T> in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Return Type CompletableFuture<Message> to CompletableFuture<Message<T>> in method public receiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Return Type Producer to Producer<T> in method public create() : Producer<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public readerListener(readerListener ReaderListener) : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public topicsPattern(topicsPattern Pattern) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public cryptoKeyReader(cryptoKeyReader CryptoKeyReader) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method public build() : Message<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type ConsumerConfigurationData to ConsumerConfigurationData<T> in method private getInternalConsumerConfig() : ConsumerConfigurationData<T> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public cryptoKeyReader(cryptoKeyReader CryptoKeyReader) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Producer> to CompletableFuture<Producer<byte[]>> in method public createProducerAsync(topic String, conf ProducerConfiguration) : CompletableFuture<Producer<byte[]>> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<byte[]> in method public newConsumer() : ConsumerBuilder<byte[]> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<byte[]> in method public newProducer() : ProducerBuilder<byte[]> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setSequenceId(sequenceId long) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setContent(data byte[]) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type Message to Message<T> in method public build() : Message<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public receiverQueueSize(receiverQueueSize int) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<T>> in method public subscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public readCompacted(readCompacted boolean) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<T>> in method public subscribeFuture() : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public cryptoKeyReader(cryptoKeyReader CryptoKeyReader) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public addEncryptionKey(key String) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public cryptoKeyReader(cryptoKeyReader CryptoKeyReader) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public property(key String, value String) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public property(key String, value String) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public topic(topicNames String...) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public cryptoKeyReader(cryptoKeyReader CryptoKeyReader) : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public messageRouter(messageRouter MessageRouter) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public messageListener(messageListener MessageListener<T>) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public enableBatching(batchMessagesEnabled boolean) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Reader> to CompletableFuture<Reader<byte[]>> in method public createReaderAsync(topic String, startMessageId MessageId, conf ReaderConfiguration) : CompletableFuture<Reader<byte[]>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type Message to Message<T> in method public readNext() : Message<T> in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public maxTotalReceiverQueueSizeAcrossPartitions(maxTotalReceiverQueueSizeAcrossPartitions int) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public ackTimeout(ackTimeout long, timeUnit TimeUnit) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public hashingScheme(hashingScheme HashingScheme) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public cryptoKeyReader(cryptoKeyReader CryptoKeyReader) : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public topic(topicName String) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type CompletableFuture<Message> to CompletableFuture<Message<T>> in method protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<T>> in method private patternTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public receiverQueueSize(receiverQueueSize int) : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<byte[]> in method public newReader() : ReaderBuilder<byte[]> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public properties(properties Map<String,String>) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public properties(properties Map<String,String>) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setEventTime(timestamp long) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type ReaderConfigurationData to ReaderConfigurationData<byte[]> in method public getReaderConfigurationData() : ReaderConfigurationData<byte[]> in class org.apache.pulsar.client.api.ReaderConfiguration |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public maxPendingMessages(maxPendingMessages int) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method protected internalReceive() : Message<T> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Return Type Consumer to Consumer<byte[]> in method public subscribe(topic String, subscription String, conf ConsumerConfiguration) : Consumer<byte[]> in class org.apache.pulsar.client.api.PulsarClient |
From |
To |
|
Change Return Type ConsumerConfigurationData to ConsumerConfigurationData<T> in method public clone() : ConsumerConfigurationData<T> in class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Change Return Type Message to Message<T> in method public receive() : Message<T> in class org.apache.pulsar.client.api.Consumer |
From |
To |
|
Change Return Type CompletableFuture<Message> to CompletableFuture<Message<T>> in method protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Return Type CompletableFuture<Message> to CompletableFuture<Message<T>> in method public readNextAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.api.Reader |
From |
To |
|
Change Return Type ReaderListener to ReaderListener<byte[]> in method public getReaderListener() : ReaderListener<byte[]> in class org.apache.pulsar.client.api.ReaderConfiguration |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setProperties(properties Map<String,String>) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setProperties(properties Map<String,String>) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Consumer> to CompletableFuture<Consumer<T>> in method public subscribeAsync() : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public subscriptionType(subscriptionType SubscriptionType) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Reader> to CompletableFuture<Reader<T>> in method public createAsync() : CompletableFuture<Reader<T>> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setContent(buf ByteBuffer) : MessageBuilder<T> in class org.apache.pulsar.client.api.MessageBuilder |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public batchingMaxMessages(batchMessagesMaxMessagesPerBatch int) : ProducerBuilder<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public clone() : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public clone() : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public readCompacted(readCompacted boolean) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type MessageBuilder to MessageBuilder<T> in method public setContent(buf ByteBuffer) : MessageBuilder<T> in class org.apache.pulsar.client.impl.MessageBuilderImpl |
From |
To |
|
Change Return Type CompletableFuture<Message> to CompletableFuture<Message<T>> in method protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public readerName(readerName String) : ReaderBuilder<T> in class org.apache.pulsar.client.api.ReaderBuilder |
From |
To |
|
Change Return Type ConsumerConfigurationData to ConsumerConfigurationData<byte[]> in method public getConfigurationData() : ConsumerConfigurationData<byte[]> in class org.apache.pulsar.client.api.ConsumerConfiguration |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public createProducer(topic String) : Producer<byte[]> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Return Type Producer to Producer<T> in method public create() : Producer<T> in class org.apache.pulsar.client.impl.ProducerBuilderImpl |
From |
To |
|
Change Return Type Message to Message<T> in method protected abstract internalReceive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public subscriptionType(subscriptionType SubscriptionType) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Return Type ConsumerBuilder to ConsumerBuilder<T> in method public topicsPattern(topicsPattern String) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Return Type ReaderBuilder to ReaderBuilder<T> in method public cryptoFailureAction(action ConsumerCryptoFailureAction) : ReaderBuilder<T> in class org.apache.pulsar.client.impl.ReaderBuilderImpl |
From |
To |
|
Change Return Type ProducerBuilder to ProducerBuilder<T> in method public initialSequenceId(initialSequenceId long) : ProducerBuilder<T> in class org.apache.pulsar.client.api.ProducerBuilder |
From |
To |
|
Change Return Type Message to Message<T> in method protected abstract internalReceive() : Message<T> in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Variable Type msg : Message to msg : Message<T> in method package messageReceived(messageId MessageIdData, headersAndPayload ByteBuf, cnx ClientCnx) : void in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Variable Type subscribeFuture1 : CompletableFuture<Consumer> to subscribeFuture1 : CompletableFuture<Consumer<byte[]>> in method public testActiveConsumerFailoverWithDelay() : void in class org.apache.pulsar.broker.service.PersistentFailoverE2ETest |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type producer1 : Producer to producer1 : Producer<byte[]> in method public testAsyncConsumer() : void in class org.apache.pulsar.client.impl.TopicsConsumerImplTest |
From |
To |
|
Change Variable Type result : CompletableFuture<Message> to result : CompletableFuture<Message<T>> in method protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type futures : List<Future<Producer>> to futures : List<Future<Producer<byte[]>>> in method public main(args String[]) : void in class org.apache.pulsar.testclient.PerformanceProducer |
From |
To |
|
Change Variable Type futures : List<Future<Consumer>> to futures : List<Future<Consumer<byte[]>>> in method public main(args String[]) : void in class org.apache.pulsar.testclient.PerformanceConsumer |
From |
To |
|
Change Variable Type receiveFuture : CompletableFuture<Message> to receiveFuture : CompletableFuture<Message<T>> in method private failPendingReceive() : void in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type consumerSubscribedFuture : CompletableFuture<Consumer> to consumerSubscribedFuture : CompletableFuture<Consumer<T>> in method private multiTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method private removeExpiredMessagesFromQueue(messageIds Set<MessageId>) : int in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type consumer2 : Consumer to consumer2 : Consumer<byte[]> in method public testConsumerBlockingWithUnAckedMessagesAtDispatcher() : void in class org.apache.pulsar.client.api.DispatcherBlockConsumerTest |
From |
To |
|
Change Variable Type consumer : Consumer to consumer : Consumer<byte[]> in method public testSharedAckedPartitionedTopic() : void in class org.apache.pulsar.client.impl.PerMessageUnAcknowledgedRedeliveryTest |
From |
To |
|
Change Variable Type producer3 : Producer to producer3 : Producer<byte[]> in method public testAsyncConsumer() : void in class org.apache.pulsar.client.impl.TopicsConsumerImplTest |
From |
To |
|
Change Variable Type subscribeFuture2 : CompletableFuture<Consumer> to subscribeFuture2 : CompletableFuture<Consumer<byte[]>> in method public testActiveConsumerFailoverWithDelay() : void in class org.apache.pulsar.broker.service.PersistentFailoverE2ETest |
From |
To |
|
Change Variable Type consumer : ConsumerImpl to consumer : ConsumerImpl<T> in method private starReceivingMessages() : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type msg : Message to msg : Message<T> in method public ReaderImpl(client PulsarClientImpl, readerConfiguration ReaderConfigurationData<T>, listenerExecutor ExecutorService, consumerFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Variable Type consumer : Consumer to consumer : Consumer<T> in method public ReaderImpl(client PulsarClientImpl, readerConfiguration ReaderConfigurationData<T>, listenerExecutor ExecutorService, consumerFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type receivedFuture : CompletableFuture<Message> to receivedFuture : CompletableFuture<Message<T>> in method private messageReceived(consumer ConsumerImpl, message Message) : void in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Variable Type confData : ConsumerConfigurationData to confData : ConsumerConfigurationData<byte[]> in method public subscribeAsync(topic String, subscription String, conf ConsumerConfiguration) : CompletableFuture<Consumer<byte[]>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type readerListener : ReaderListener to readerListener : ReaderListener<T> in method public ReaderImpl(client PulsarClientImpl, readerConfiguration ReaderConfigurationData<T>, listenerExecutor ExecutorService, consumerFuture CompletableFuture<Consumer<T>>, schema Schema<T>) in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type pc : PartitionedConsumerImpl to pc : PartitionedConsumerImpl<byte[]> in method private getUnackedMessagesCountInPartitionedConsumer(c Consumer<byte[]>) : long in class org.apache.pulsar.client.impl.PerMessageUnAcknowledgedRedeliveryTest |
From |
To |
|
Change Variable Type consumer3 : Consumer to consumer3 : Consumer<byte[]> in method public testConsumerBlockingWithUnAckedMessagesAtDispatcher() : void in class org.apache.pulsar.client.api.DispatcherBlockConsumerTest |
From |
To |
|
Change Variable Type receivedFuture : CompletableFuture<Message> to receivedFuture : CompletableFuture<Message<T>> in method package messageReceived(message Message<T>) : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type msg : Message to msg : Message<T> in method public readNext() : Message<T> in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Variable Type future : Future<Consumer> to future : Future<Consumer<byte[]>> in method public main(args String[]) : void in class org.apache.pulsar.testclient.PerformanceConsumer |
From |
To |
|
Change Variable Type future : Future<Producer> to future : Future<Producer<byte[]>> in method public main(args String[]) : void in class org.apache.pulsar.testclient.PerformanceProducer |
From |
To |
|
Change Variable Type consumersToUnsub : List<ConsumerImpl> to consumersToUnsub : List<ConsumerImpl<T>> in method public unsubscribeAsync(topicName String) : CompletableFuture<Void> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Variable Type result : CompletableFuture<Message> to result : CompletableFuture<Message<T>> in method protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Variable Type confData : ReaderConfigurationData to confData : ReaderConfigurationData<byte[]> in method public createReaderAsync(topic String, startMessageId MessageId, conf ReaderConfiguration) : CompletableFuture<Reader<byte[]>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type future : CompletableFuture<org.apache.pulsar.client.api.Consumer> to future : CompletableFuture<org.apache.pulsar.client.api.Consumer<byte[]>> in method public subscribe(topics Collection<String>, callback ConsumerRebalanceListener) : void in class org.apache.kafka.clients.consumer.PulsarKafkaConsumer |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method public main(args String[]) : void in class org.apache.pulsar.testclient.PerformanceProducer |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method private fetchSingleMessageFromBroker() : Message<T> in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type future : CompletableFuture<Consumer> to future : CompletableFuture<Consumer<byte[]>> in method public create(client PulsarClient, topic String, subscription String) : CompletableFuture<RawReader> in class org.apache.pulsar.client.api.RawReader |
From |
To |
|
Change Variable Type receiveFuture : CompletableFuture<Message> to receiveFuture : CompletableFuture<Message<T>> in method private failPendingReceive() : void in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Variable Type producers : List<Producer> to producers : List<Producer<byte[]>> in method public main(args String[]) : void in class org.apache.pulsar.testclient.PerformanceProducer |
From |
To |
|
Change Variable Type receivedFuture : CompletableFuture<Message> to receivedFuture : CompletableFuture<Message<T>> in method package notifyPendingReceivedCallback(message Message<T>, exception Exception) : void in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type consumer : Consumer to consumer : Consumer<T> in method public unsubscribeAsync() : CompletableFuture<Void> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Variable Type receiveFuture : CompletableFuture<Message> to receiveFuture : CompletableFuture<Message<T>> in method private failPendingReceive() : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type readerFuture : CompletableFuture<Reader> to readerFuture : CompletableFuture<Reader<T>> in method public createReaderAsync(conf ReaderConfigurationData<T>, schema Schema<T>) : CompletableFuture<Reader<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type producer2 : Producer to producer2 : Producer<byte[]> in method public testAsyncConsumer() : void in class org.apache.pulsar.client.impl.TopicsConsumerImplTest |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public execute(input Tuple) : void in class org.apache.pulsar.storm.PulsarBolt |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceive() : Message<T> in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceive() : Message<T> in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type msg : Message to msg : Message<T> in method package messageReceived(message Message<T>) : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type internalConfig : ConsumerConfigurationData to internalConfig : ConsumerConfigurationData<T> in method private start() : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type consumer : Consumer to consumer : Consumer<byte[]> in method public testBatchMessagesRateOut() : void in class org.apache.pulsar.client.api.SimpleProducerConsumerStatTest |
From |
To |
|
Change Variable Type consumer : Consumer to consumer : Consumer<byte[]> in method public testAsyncConsumer() : void in class org.apache.pulsar.client.impl.TopicsConsumerImplTest |
From |
To |
|
Change Variable Type futures : List<CompletableFuture<org.apache.pulsar.client.api.Consumer>> to futures : List<CompletableFuture<org.apache.pulsar.client.api.Consumer<byte[]>>> in method public subscribe(topics Collection<String>, callback ConsumerRebalanceListener) : void in class org.apache.kafka.clients.consumer.PulsarKafkaConsumer |
From |
To |
|
Change Variable Type peek : Message to peek : Message<T> in method private removeExpiredMessagesFromQueue(messageIds Set<MessageId>) : int in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Variable Type futures : List<CompletableFuture<Producer>> to futures : List<CompletableFuture<Producer<byte[]>>> in method public testMaxConcurrentTopicLoading() : void in class org.apache.pulsar.client.impl.BrokerClientIntegrationTest |
From |
To |
|
Change Variable Type msg : MessageImpl to msg : MessageImpl<byte[]> in method package create(msgMetadataBuilder MessageMetadata.Builder, payload ByteBuffer) : MessageImpl<byte[]> in class org.apache.pulsar.client.impl.MessageImpl |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method private removeExpiredMessagesFromQueue(messageIds Set<MessageId>) : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type consumerSubscribedFuture : CompletableFuture<Consumer> to consumerSubscribedFuture : CompletableFuture<Consumer<T>> in method private singleTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type consumerSubscribedFuture : CompletableFuture<Consumer> to consumerSubscribedFuture : CompletableFuture<Consumer<T>> in method private patternTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type msg : Message to msg : Message<byte[]> in method public onWebSocketText(message String) : void in class org.apache.pulsar.websocket.ProducerHandler |
From |
To |
|
Change Variable Type consumerSub2 : ConsumerImpl to consumerSub2 : ConsumerImpl<byte[]> in method public testBlockBrokerDispatching() : void in class org.apache.pulsar.client.api.DispatcherBlockConsumerTest |
From |
To |
|
Change Variable Type message : Message to message : Message<T> in method protected internalReceive() : Message<T> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type futures : List<CompletableFuture<Reader>> to futures : List<CompletableFuture<Reader<byte[]>>> in method public main(args String[]) : void in class org.apache.pulsar.testclient.PerformanceReader |
From |
To |
|
Change Variable Type msg : Message to msg : Message<T> in method public readNext(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Variable Type producerCreatedFuture : CompletableFuture<Producer> to producerCreatedFuture : CompletableFuture<Producer<T>> in method public createProducerAsync(conf ProducerConfigurationData, schema Schema<T>) : CompletableFuture<Producer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<T> in method public closeAsync() : CompletableFuture<Void> in class org.apache.pulsar.client.impl.PartitionedProducerImpl |
From |
To |
|
Change Variable Type consumer : ConsumerImpl to consumer : ConsumerImpl<T> in method protected doAcknowledge(messageId MessageId, ackType AckType, properties Map<String,Long>) : CompletableFuture<Void> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type consumer : Consumer to consumer : Consumer<T> in method public closeAsync() : CompletableFuture<Void> in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type peek : Message to peek : Message<T> in method private removeExpiredMessagesFromQueue(messageIds Set<MessageId>) : void in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Variable Type consumer1 : Consumer to consumer1 : Consumer<byte[]> in method public testConsumerBlockingWithUnAckedMessagesAtDispatcher() : void in class org.apache.pulsar.client.api.DispatcherBlockConsumerTest |
From |
To |