|
Pull Up Method public getPartitionedTopicMetadata(property String, cluster String, namespace String, destination String, authoritative boolean) : PartitionedTopicMetadata from class org.apache.pulsar.broker.admin.PersistentTopics to protected getPartitionedTopicMetadata(property String, cluster String, namespace String, destination String, authoritative boolean) : PartitionedTopicMetadata from class org.apache.pulsar.broker.admin.AdminResource |
From |
To |
|
Pull Up Method public addConsumer(consumer Consumer) : void from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public addConsumer(consumer Consumer) : void from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method public startProducer() : void from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to public startProducer() : void from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method private getNextConsumer() : Consumer from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to public getNextConsumer() : Consumer from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Method public canUnsubscribe(consumer Consumer) : boolean from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public canUnsubscribe(consumer Consumer) : boolean from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method public getRemoteCluster() : String from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to public getRemoteCluster() : String from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method public removeConsumer(consumer Consumer) : void from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public removeConsumer(consumer Consumer) : void from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method private getConsumerFromHigherPriority(targetPriority int) : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to private getConsumerFromHigherPriority(targetPriority int) : int from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Method public getType() : SubType from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public getType() : SubType from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method private closeProducerAsync() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected closeProducerAsync() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method private fetchPartitionedTopicMetadataAsync(pulsar PulsarService, path String) : CompletableFuture<PartitionedTopicMetadata> from class org.apache.pulsar.broker.admin.PersistentTopics to protected fetchPartitionedTopicMetadataAsync(pulsar PulsarService, path String) : CompletableFuture<PartitionedTopicMetadata> from class org.apache.pulsar.broker.admin.AdminResource |
From |
To |
|
Pull Up Method public close() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public close() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method public reset() : void from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public reset() : void from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method private getNextConsumerFromSameOrLowerLevel(currentRoundRobinIndex int) : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to private getNextConsumerFromSameOrLowerLevel(currentRoundRobinIndex int) : int from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Method public getConsumers() : CopyOnWriteArrayList<Consumer> from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public getConsumers() : CopyOnWriteArrayList<Consumer> from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method public getReplicatorName(replicatorPrefix String, cluster String) : String from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to public getReplicatorName(replicatorPrefix String, cluster String) : String from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method public remove() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to public remove() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method public disconnect(failIfHasBacklog boolean) : CompletableFuture<Void> from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to public disconnect(failIfHasBacklog boolean) : CompletableFuture<Void> from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method public setReplicatorQueueSize(queueSize int) : void from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to public setReplicatorQueueSize(queueSize int) : void from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method public getRemoteCluster(remoteCursor String) : String from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to public getRemoteCluster(remoteCursor String) : String from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method public disconnect() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to public disconnect() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method private fetchPartitionedTopicMetadata(pulsar PulsarService, path String) : PartitionedTopicMetadata from class org.apache.pulsar.broker.admin.PersistentTopics to protected fetchPartitionedTopicMetadata(pulsar PulsarService, path String) : PartitionedTopicMetadata from class org.apache.pulsar.broker.admin.AdminResource |
From |
To |
|
Pull Up Method public getActiveConsumer() : Consumer from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public getActiveConsumer() : Consumer from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method public disconnectAllConsumers() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public disconnectAllConsumers() : CompletableFuture<Void> from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method private isWritable() : boolean from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected isWritable() : boolean from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Method public isConsumerConnected() : boolean from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to public isConsumerConnected() : boolean from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method private pickAndScheduleActiveConsumer() : void from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to protected pickAndScheduleActiveConsumer() : void from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Method private getFirstConsumerIndexOfPriority(targetPriority int) : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to private getFirstConsumerIndexOfPriority(targetPriority int) : int from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Attribute private producerConfiguration : ProducerConfiguration from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected producerConfiguration : ProducerConfiguration from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Attribute private topicName : String from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected topicName : String from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Attribute private isClosed : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to private isClosed : int from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Attribute private subscriptionType : SubType from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to protected subscriptionType : SubType from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Attribute private consumerSet : ObjectSet<Consumer> from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to protected consumerSet : ObjectSet<Consumer> from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Attribute private FALSE : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to protected FALSE : int from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Attribute private currentConsumerRoundRobinIndex : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to protected currentConsumerRoundRobinIndex : int from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Attribute private FALSE : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to protected FALSE : int from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Attribute private state : State from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to private state : State from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Attribute private remoteCluster : String from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected remoteCluster : String from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Attribute private closeFuture : CompletableFuture<Void> from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to protected closeFuture : CompletableFuture<Void> from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Attribute private localCluster : String from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected localCluster : String from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Attribute private client : PulsarClientImpl from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected client : PulsarClientImpl from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Attribute private brokerService : BrokerService from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected brokerService : BrokerService from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Attribute private consumerList : CopyOnWriteArrayList<Consumer> from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to protected consumerList : CopyOnWriteArrayList<Consumer> from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Attribute private isClosed : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to private isClosed : int from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Attribute private partitionIndex : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to protected partitionIndex : int from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Attribute private backOff : Backoff from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected backOff : Backoff from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Pull Up Attribute private consumers : CopyOnWriteArrayList<Consumer> from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to protected consumers : CopyOnWriteArrayList<Consumer> from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Attribute private activeConsumer : Consumer from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to private activeConsumer : Consumer from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Attribute private PARTITIONED_TOPIC_PATH_ZNODE : String from class org.apache.pulsar.broker.admin.PersistentTopics to public PARTITIONED_TOPIC_PATH_ZNODE : String from class org.apache.pulsar.broker.admin.AdminResource |
From |
To |
|
Pull Up Attribute private TRUE : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer to protected TRUE : int from class org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer |
From |
To |
|
Pull Up Attribute private TRUE : int from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers to protected TRUE : int from class org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers |
From |
To |
|
Pull Up Attribute private producer : ProducerImpl from class org.apache.pulsar.broker.service.persistent.PersistentReplicator to protected producer : ProducerImpl from class org.apache.pulsar.broker.service.AbstractReplicator |
From |
To |
|
Change Return Type CompletableFuture<? extends Subscription> to CompletableFuture<Subscription> in method private getDurableSubscription(subscriptionName String) : CompletableFuture<Subscription> in class org.apache.pulsar.broker.service.persistent.PersistentTopic |
From |
To |
|
Change Return Type ConcurrentOpenHashMap<String,ConcurrentOpenHashMap<String,ConcurrentOpenHashMap<String,PersistentTopic>>> to ConcurrentOpenHashMap<String,ConcurrentOpenHashMap<String,ConcurrentOpenHashMap<String,Topic>>> in method public getMultiLayerTopicMap() : ConcurrentOpenHashMap<String,ConcurrentOpenHashMap<String,ConcurrentOpenHashMap<String,Topic>>> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Return Type ConcurrentOpenHashMap<String,PersistentReplicator> to ConcurrentOpenHashMap<String,Replicator> in method public getReplicators() : ConcurrentOpenHashMap<String,Replicator> in class org.apache.pulsar.broker.service.persistent.PersistentTopic |
From |
To |
|
Change Return Type CompletableFuture<PersistentSubscription> to CompletableFuture<Subscription> in method public createSubscription(subscriptionName String) : CompletableFuture<Subscription> in class org.apache.pulsar.broker.service.persistent.PersistentTopic |
From |
To |
|
Change Return Type PersistentTopic to Topic in method private getTopicReference(dn DestinationName) : Topic in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Return Type PersistentSubscriptionStats to SubscriptionStats in method public getStats() : SubscriptionStats in class org.apache.pulsar.broker.service.persistent.PersistentSubscription |
From |
To |
|
Change Return Type PersistentSubscriptionStats to SubscriptionStats in method public add(stats SubscriptionStats) : SubscriptionStats in class org.apache.pulsar.common.policies.data.SubscriptionStats |
From |
To |
|
Change Return Type PersistentSubscription to Subscription in method private getSubscriptionReference(subName String, topic PersistentTopic) : Subscription in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Return Type CompletableFuture<PersistentSubscription> to CompletableFuture<Subscription> in method public createSubscription(subscriptionName String) : CompletableFuture<Subscription> in class org.apache.pulsar.broker.service.Topic |
From |
To |
|
Change Return Type List<PersistentTopic> to List<Topic> in method public getAllTopicsFromNamespaceBundle(namespace String, bundle String) : List<Topic> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Return Type PersistentReplicator to Replicator in method public getPersistentReplicator(remoteCluster String) : Replicator in class org.apache.pulsar.broker.service.persistent.PersistentTopic |
From |
To |
|
Change Return Type ConcurrentOpenHashMap<String,PersistentSubscription> to ConcurrentOpenHashMap<String,? extends Subscription> in method public getSubscriptions() : ConcurrentOpenHashMap<String,? extends Subscription> in class org.apache.pulsar.broker.service.Topic |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method public deleteSubscription(property String, cluster String, namespace String, destination String, subName String, authoritative boolean) : void in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method public terminate(property String, cluster String, namespace String, destination String, authoritative boolean) : MessageId in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method private unsubscribe(nsName NamespaceName, bundleRange String, subscription String) : void in class org.apache.pulsar.broker.admin.Namespaces |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method private clearBacklog(nsName NamespaceName, bundleRange String, subscription String) : void in class org.apache.pulsar.broker.admin.Namespaces |
From |
To |
|
Change Variable Type replicatorMap : ConcurrentOpenHashMap<String,PersistentReplicator> to replicatorMap : ConcurrentOpenHashMap<String,Replicator> in method public testAtomicReplicationRemoval() : void in class org.apache.pulsar.broker.service.PersistentTopicTest |
From |
To |
|
Change Variable Type topicList : List<PersistentTopic> to topicList : List<Topic> in method private unsubscribe(nsName NamespaceName, bundleRange String, subscription String) : void in class org.apache.pulsar.broker.admin.Namespaces |
From |
To |
|
Change Variable Type sub : PersistentSubscription to sub : Subscription in method public deleteSubscription(property String, cluster String, namespace String, destination String, subName String, authoritative boolean) : void in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type list : List<PersistentTopic> to list : List<Topic> in method public testSplitMapWithRefreshedStatMap() : void in class org.apache.pulsar.broker.namespace.NamespaceServiceTest |
From |
To |
|
Change Variable Type bundleMap : ConcurrentOpenHashMap<String,PersistentTopic> to bundleMap : ConcurrentOpenHashMap<String,Topic> in method public removeTopicFromCache(topic String) : void in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type subStats : PersistentSubscriptionStats to subStats : SubscriptionStats in method public getStats() : PersistentTopicStats in class org.apache.pulsar.broker.service.persistent.PersistentTopic |
From |
To |
|
Change Variable Type subStats : PersistentSubscriptionStats to subStats : SubscriptionStats in method public testBrokerServicePersistentTopicStats() : void in class org.apache.pulsar.broker.service.BrokerServiceTest |
From |
To |
|
Change Variable Type sub : PersistentSubscription to sub : Subscription in method private getSubscriptionReference(subName String, topic PersistentTopic) : Subscription in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method private getTopicReference(dn DestinationName) : Topic in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method public getInternalStats(property String, cluster String, namespace String, destination String, authoritative boolean) : PersistentTopicInternalStats in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type topics : List<PersistentTopic> to topics : List<Topic> in method public refreshTopicToStatsMaps(oldBundle NamespaceBundle) : void in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method public getSubscriptions(property String, cluster String, namespace String, destination String, authoritative boolean) : List<String> in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method public getStats(property String, cluster String, namespace String, destination String, authoritative boolean) : PersistentTopicStats in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type subStats : PersistentSubscriptionStats to subStats : SubscriptionStats in method public testBrokerServicePersistentRedeliverTopicStats() : void in class org.apache.pulsar.broker.service.BrokerServiceTest |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method public deleteTopic(property String, cluster String, namespace String, destination String, authoritative boolean) : void in class org.apache.pulsar.broker.admin.PersistentTopics |
From |
To |
|
Change Variable Type namespaceMap : ConcurrentOpenHashMap<String,ConcurrentOpenHashMap<String,PersistentTopic>> to namespaceMap : ConcurrentOpenHashMap<String,ConcurrentOpenHashMap<String,Topic>> in method public removeTopicFromCache(topic String) : void in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type subscriptionStats : PersistentSubscriptionStats to subscriptionStats : SubscriptionStats in method public add(stats PersistentTopicStats) : PersistentTopicStats in class org.apache.pulsar.common.policies.data.PersistentTopicStats |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method public checkGC(gcIntervalInSeconds int) : void in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type topic : PersistentTopic to topic : Topic in method public checkMessageExpiry() : void in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type subStats : PersistentSubscriptionStats to subStats : SubscriptionStats in method public testBlockDispatcherStats() : void in class org.apache.pulsar.client.api.DispatcherBlockConsumerTest |
From |
To |
|
Change Variable Type sub : PersistentSubscription to sub : Subscription in method private unsubscribe(nsName NamespaceName, bundleRange String, subscription String) : void in class org.apache.pulsar.broker.admin.Namespaces |
From |
To |
|
Change Variable Type topicList : List<PersistentTopic> to topicList : List<Topic> in method private clearBacklog(nsName NamespaceName, bundleRange String, subscription String) : void in class org.apache.pulsar.broker.admin.Namespaces |
From |
To |
|
Change Variable Type currentTopic : PersistentTopic to currentTopic : Topic in method public getTopicStats() : Map<String,PersistentTopicStats> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type subStats : PersistentSubscriptionStats to subStats : SubscriptionStats in method public getStats() : SubscriptionStats in class org.apache.pulsar.broker.service.persistent.PersistentSubscription |
From |
To |