|
Change Parameter Type conf : ConsumerConfiguration to conf : ConsumerConfigurationData in method public ConsumerStats(pulsarClient PulsarClientImpl, conf ConsumerConfigurationData, consumer ConsumerImpl) in class org.apache.pulsar.client.impl.ConsumerStats |
From |
To |
|
Change Parameter Type conf : ProducerConfiguration to conf : ProducerConfigurationData in method public ProducerStats(pulsarClient PulsarClientImpl, conf ProducerConfigurationData, producer ProducerImpl) in class org.apache.pulsar.client.impl.ProducerStats |
From |
To |
|
Change Parameter Type conf : ConsumerConfiguration to conf : ConsumerConfigurationData in method package ConsumerImpl(client PulsarClientImpl, topic String, conf ConsumerConfigurationData, listenerExecutor ExecutorService, partitionIndex int, subscribeFuture CompletableFuture<Consumer>) in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Parameter Type conf : ProducerConfiguration to conf : ProducerConfigurationData in method private init(conf ProducerConfigurationData) : void in class org.apache.pulsar.client.impl.ProducerStats |
From |
To |
|
Change Parameter Type conf : ConsumerConfiguration to conf : ConsumerConfigurationData in method private init(conf ConsumerConfigurationData) : void in class org.apache.pulsar.client.impl.ConsumerStats |
From |
To |
|
Change Parameter Type conf : ConsumerConfiguration to conf : ConsumerConfigurationData in method protected ConsumerBase(client PulsarClientImpl, topic String, conf ConsumerConfigurationData, receiverQueueSize int, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer>) in class org.apache.pulsar.client.impl.ConsumerBase |
From |
To |
|
Change Parameter Type hashingScheme : ProducerConfiguration.HashingScheme to hashingScheme : HashingScheme in method package MessageRouterBase(hashingScheme HashingScheme) in class org.apache.pulsar.client.impl.MessageRouterBase |
From |
To |
|
Change Parameter Type conf : ConsumerConfiguration to conf : ConsumerConfigurationData in method package TopicsConsumerImpl(client PulsarClientImpl, conf ConsumerConfigurationData, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer>) in class org.apache.pulsar.client.impl.TopicsConsumerImpl |
From |
To |
|
Change Parameter Type conf : ClientConfiguration to conf : ClientConfigurationData in method public ClientCnx(conf ClientConfigurationData, eventLoopGroup EventLoopGroup) in class org.apache.pulsar.client.impl.ClientCnx |
From |
To |
|
Change Parameter Type conf : ConsumerConfiguration to conf : ConsumerConfigurationData in method package ConsumerImpl(client PulsarClientImpl, topic String, conf ConsumerConfigurationData, listenerExecutor ExecutorService, partitionIndex int, subscribeFuture CompletableFuture<Consumer>, subscriptionMode SubscriptionMode, startMessageId MessageId) in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Parameter Type encKeys : ConcurrentOpenHashSet<String> to encKeys : Set<String> in method public encrypt(encKeys Set<String>, keyReader CryptoKeyReader, msgMetadata MessageMetadata.Builder, payload ByteBuf) : ByteBuf in class org.apache.pulsar.client.impl.MessageCrypto |
From |
To |
|
Change Parameter Type readerConfiguration : ReaderConfiguration to readerConfiguration : ReaderConfigurationData in method public ReaderImpl(client PulsarClientImpl, readerConfiguration ReaderConfigurationData, listenerExecutor ExecutorService, consumerFuture CompletableFuture<Consumer>) in class org.apache.pulsar.client.impl.ReaderImpl |
From |
To |
|
Change Parameter Type conf : ConsumerConfiguration to conf : ConsumerConfigurationData in method package RawConsumerImpl(client PulsarClientImpl, conf ConsumerConfigurationData, consumerFuture CompletableFuture<Consumer>) in class org.apache.pulsar.client.impl.RawReaderImpl.RawConsumerImpl |
From |
To |
|
Change Parameter Type conf : ClientConfiguration to conf : ClientConfigurationData in method private getEventLoopGroup(conf ClientConfigurationData) : EventLoopGroup in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Parameter Type conf : ClientConfiguration to conf : ClientConfigurationData in method public HttpLookupService(conf ClientConfigurationData, eventLoopGroup EventLoopGroup) in class org.apache.pulsar.client.impl.HttpLookupService |
From |
To |
|
Change Parameter Type conf : ProducerConfiguration to conf : ProducerConfigurationData in method protected ProducerBase(client PulsarClientImpl, topic String, conf ProducerConfigurationData, producerCreatedFuture CompletableFuture<Producer>) in class org.apache.pulsar.client.impl.ProducerBase |
From |
To |
|
Change Parameter Type conf : ConsumerConfiguration to conf : ConsumerConfigurationData in method package PartitionedConsumerImpl(client PulsarClientImpl, conf ConsumerConfigurationData, numPartitions int, listenerExecutor ExecutorService, subscribeFuture CompletableFuture<Consumer>) in class org.apache.pulsar.client.impl.PartitionedConsumerImpl |
From |
To |
|
Change Parameter Type hashingScheme : ProducerConfiguration.HashingScheme to hashingScheme : HashingScheme in method public RoundRobinPartitionMessageRouterImpl(hashingScheme HashingScheme) in class org.apache.pulsar.client.impl.RoundRobinPartitionMessageRouterImpl |
From |
To |
|
Change Parameter Type conf : ProducerConfiguration to conf : ProducerConfigurationData in method public ProducerImpl(client PulsarClientImpl, topic String, conf ProducerConfigurationData, producerCreatedFuture CompletableFuture<Producer>, partitionIndex int) in class org.apache.pulsar.client.impl.ProducerImpl |
From |
To |
|
Change Parameter Type conf : ClientConfiguration to conf : ClientConfigurationData in method public ConnectionPool(conf ClientConfigurationData, eventLoopGroup EventLoopGroup) in class org.apache.pulsar.client.impl.ConnectionPool |
From |
To |
|
Change Parameter Type hashingScheme : ProducerConfiguration.HashingScheme to hashingScheme : HashingScheme in method public SinglePartitionMessageRouterImpl(partitionIndex int, hashingScheme HashingScheme) in class org.apache.pulsar.client.impl.SinglePartitionMessageRouterImpl |
From |
To |
|
Change Parameter Type conf : ProducerConfiguration to conf : ProducerConfigurationData in method public PartitionedProducerImpl(client PulsarClientImpl, topic String, conf ProducerConfigurationData, numPartitions int, producerCreatedFuture CompletableFuture<Producer>) in class org.apache.pulsar.client.impl.PartitionedProducerImpl |
From |
To |
|
Move Attribute private receiverQueueSize : int from class org.apache.pulsar.client.api.ReaderConfiguration to private receiverQueueSize : int from class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Move Attribute private authentication : Authentication from class org.apache.pulsar.client.api.ClientConfiguration to private authentication : Authentication from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private batchingMaxMessages : int from class org.apache.pulsar.client.api.ProducerConfiguration to private batchingMaxMessages : int from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private numIoThreads : int from class org.apache.pulsar.client.api.ClientConfiguration to private numIoThreads : int from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private topicName : String from class org.apache.pulsar.client.impl.ProducerBuilderImpl to private topicName : String from class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Move Attribute private maxPendingMessagesAcrossPartitions : int from class org.apache.pulsar.client.api.ProducerConfiguration to private maxPendingMessagesAcrossPartitions : int from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private tlsAllowInsecureConnection : boolean from class org.apache.pulsar.client.api.ClientConfiguration to private tlsAllowInsecureConnection : boolean from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private initialSequenceId : Long from class org.apache.pulsar.client.api.ProducerConfiguration to private initialSequenceId : Long from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private batchingEnabled : boolean from class org.apache.pulsar.client.api.ProducerConfiguration to private batchingEnabled : boolean from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private blockIfQueueFull : boolean from class org.apache.pulsar.client.api.ProducerConfiguration to private blockIfQueueFull : boolean from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private maxNumberOfRejectedRequestPerConnection : int from class org.apache.pulsar.client.api.ClientConfiguration to private maxNumberOfRejectedRequestPerConnection : int from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private receiverQueueSize : int from class org.apache.pulsar.client.api.ConsumerConfiguration to private receiverQueueSize : int from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private tlsHostnameVerificationEnable : boolean from class org.apache.pulsar.client.api.ClientConfiguration to private tlsHostnameVerificationEnable : boolean from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private maxPendingMessages : int from class org.apache.pulsar.client.api.ProducerConfiguration to private maxPendingMessages : int from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private startMessageId : MessageId from class org.apache.pulsar.client.impl.ReaderBuilderImpl to private startMessageId : MessageId from class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Move Attribute private messageListener : MessageListener from class org.apache.pulsar.client.api.ConsumerConfiguration to private messageListener : MessageListener from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private readerName : String from class org.apache.pulsar.client.api.ReaderConfiguration to private readerName : String from class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Move Attribute private subscriptionName : String from class org.apache.pulsar.client.impl.ConsumerBuilderImpl to private subscriptionName : String from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private readCompacted : boolean from class org.apache.pulsar.client.api.ConsumerConfiguration to private readCompacted : boolean from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private concurrentLookupRequest : int from class org.apache.pulsar.client.api.ClientConfiguration to private concurrentLookupRequest : int from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private hashingScheme : HashingScheme from class org.apache.pulsar.client.api.ProducerConfiguration to private hashingScheme : HashingScheme from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private statsIntervalSeconds : long from class org.apache.pulsar.client.api.ClientConfiguration to private statsIntervalSeconds : long from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private priorityLevel : int from class org.apache.pulsar.client.api.ConsumerConfiguration to private priorityLevel : int from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private ackTimeoutMillis : long from class org.apache.pulsar.client.api.ConsumerConfiguration to private ackTimeoutMillis : long from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private customMessageRouter : MessageRouter from class org.apache.pulsar.client.api.ProducerConfiguration to private customMessageRouter : MessageRouter from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private cryptoKeyReader : CryptoKeyReader from class org.apache.pulsar.client.api.ConsumerConfiguration to private cryptoKeyReader : CryptoKeyReader from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private cryptoKeyReader : CryptoKeyReader from class org.apache.pulsar.client.api.ProducerConfiguration to private cryptoKeyReader : CryptoKeyReader from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private numListenerThreads : int from class org.apache.pulsar.client.api.ClientConfiguration to private numListenerThreads : int from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private connectionsPerBroker : int from class org.apache.pulsar.client.api.ClientConfiguration to private connectionsPerBroker : int from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private cryptoFailureAction : ConsumerCryptoFailureAction from class org.apache.pulsar.client.api.ConsumerConfiguration to private cryptoFailureAction : ConsumerCryptoFailureAction from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private cryptoFailureAction : ProducerCryptoFailureAction from class org.apache.pulsar.client.api.ProducerConfiguration to private cryptoFailureAction : ProducerCryptoFailureAction from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private cryptoFailureAction : ConsumerCryptoFailureAction from class org.apache.pulsar.client.api.ReaderConfiguration to private cryptoFailureAction : ConsumerCryptoFailureAction from class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Move Attribute private compressionType : CompressionType from class org.apache.pulsar.client.api.ProducerConfiguration to private compressionType : CompressionType from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private operationTimeoutMs : long from class org.apache.pulsar.client.api.ClientConfiguration to private operationTimeoutMs : long from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private tlsTrustCertsFilePath : String from class org.apache.pulsar.client.api.ClientConfiguration to private tlsTrustCertsFilePath : String from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private maxTotalReceiverQueueSizeAcrossPartitions : int from class org.apache.pulsar.client.api.ConsumerConfiguration to private maxTotalReceiverQueueSizeAcrossPartitions : int from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private useTls : boolean from class org.apache.pulsar.client.api.ClientConfiguration to private useTls : boolean from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private readerListener : ReaderListener from class org.apache.pulsar.client.api.ReaderConfiguration to private readerListener : ReaderListener from class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Move Attribute private cryptoKeyReader : CryptoKeyReader from class org.apache.pulsar.client.api.ReaderConfiguration to private cryptoKeyReader : CryptoKeyReader from class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Move Attribute private topicName : String from class org.apache.pulsar.client.impl.ProducerBuilderImpl to private topicName : String from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private consumerEventListener : ConsumerEventListener from class org.apache.pulsar.client.api.ConsumerConfiguration to private consumerEventListener : ConsumerEventListener from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private topicNames : Set<String> from class org.apache.pulsar.client.impl.ConsumerBuilderImpl to private topicNames : Set<String> from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private topicName : String from class org.apache.pulsar.client.impl.ReaderBuilderImpl to private topicName : String from class org.apache.pulsar.client.impl.conf.ReaderConfigurationData |
From |
To |
|
Move Attribute package serviceUrl : String from class org.apache.pulsar.client.impl.ClientBuilderImpl to private serviceUrl : String from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private useTcpNoDelay : boolean from class org.apache.pulsar.client.api.ClientConfiguration to private useTcpNoDelay : boolean from class org.apache.pulsar.client.impl.conf.ClientConfigurationData |
From |
To |
|
Move Attribute private consumerName : String from class org.apache.pulsar.client.api.ConsumerConfiguration to private consumerName : String from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |
|
Move Attribute private producerName : String from class org.apache.pulsar.client.api.ProducerConfiguration to private producerName : String from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private sendTimeoutMs : long from class org.apache.pulsar.client.api.ProducerConfiguration to private sendTimeoutMs : long from class org.apache.pulsar.client.impl.conf.ProducerConfigurationData |
From |
To |
|
Move Attribute private subscriptionType : SubscriptionType from class org.apache.pulsar.client.api.ConsumerConfiguration to private subscriptionType : SubscriptionType from class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData |
From |
To |