|
Change Return Type CompletableFuture<Topic> to CompletableFuture<Optional<Topic>> in method private createNonPersistentTopic(topic String) : CompletableFuture<Optional<Topic>> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Return Type CompletableFuture<Topic> to CompletableFuture<Optional<Topic>> in method private getTopic(topic String, createIfMissing boolean) : CompletableFuture<Optional<Topic>> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Return Type ConcurrentOpenHashMap<String,CompletableFuture<Topic>> to ConcurrentOpenHashMap<String,CompletableFuture<Optional<Topic>>> in method public getTopics() : ConcurrentOpenHashMap<String,CompletableFuture<Optional<Topic>>> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Return Type CompletableFuture<Topic> to CompletableFuture<Optional<Topic>> in method protected loadOrCreatePersistentTopic(topic String, createIfMissing boolean) : CompletableFuture<Optional<Topic>> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type pendingFuture : CompletableFuture<Topic> to pendingFuture : CompletableFuture<Optional<Topic>> in method private createPendingLoadTopic() : void in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type topicFuture : CompletableFuture<Topic> to topicFuture : CompletableFuture<Optional<Topic>> in method private getTopic(topic String, createIfMissing boolean) : CompletableFuture<Optional<Topic>> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type pendingTopic : Pair<String,CompletableFuture<Topic>> to pendingTopic : Pair<String,CompletableFuture<Optional<Topic>>> in method private createPendingLoadTopic() : void in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type future : CompletableFuture<Topic> to future : CompletableFuture<Optional<Topic>> in method public getTopicReference(topic String) : Optional<Topic> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type futureResult : CompletableFuture<Topic> to futureResult : CompletableFuture<Optional<Topic>> in method public testTopicLoadingOnDisableNamespaceBundle() : void in class org.apache.pulsar.broker.service.BrokerServiceTest |
From |
To |
|
Change Variable Type topics : ConcurrentOpenHashMap<String,CompletableFuture<Topic>> to topics : ConcurrentOpenHashMap<String,CompletableFuture<Optional<Topic>>> in method public testUnloadNamespaceBundleFailure() : void in class org.apache.pulsar.broker.namespace.NamespaceServiceTest |
From |
To |
|
Change Variable Type topicFuture : CompletableFuture<Topic> to topicFuture : CompletableFuture<Optional<Topic>> in method protected loadOrCreatePersistentTopic(topic String, createIfMissing boolean) : CompletableFuture<Optional<Topic>> in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Variable Type topicFuture : CompletableFuture<Topic> to topicFuture : CompletableFuture<Optional<Topic>> in method public testUnloadNamespaceBundleFailure() : void in class org.apache.pulsar.broker.namespace.NamespaceServiceTest |
From |
To |
|
Change Variable Type topics : ConcurrentOpenHashMap<String,CompletableFuture<Topic>> to topics : ConcurrentOpenHashMap<String,CompletableFuture<Optional<Topic>>> in method public testUnloadNamespaceBundleWithStuckTopic() : void in class org.apache.pulsar.broker.namespace.NamespaceServiceTest |
From |
To |
|
Change Variable Type topicFuture : CompletableFuture<Topic> to topicFuture : CompletableFuture<Optional<Topic>> in method public testUnloadNamespaceBundleWithStuckTopic() : void in class org.apache.pulsar.broker.namespace.NamespaceServiceTest |
From |
To |