22e45e70c593118af849a17cad2c2de433344625
Files Diff
- Added: 6
- Removed: 2
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Rename Method | 1 | ||
| Move And Rename Method private startInputConsumer() : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to public setupInput(inputSerDe Map<String,SerDe>) : void from class org.apache.pulsar.functions.instance.processors.MessageProcessorBase | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type consumer : Consumer to consumer : Consumer<?> in method public becameActive(consumer Consumer<?>, partitionId int) : void in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Change Parameter Type consumer : Consumer to consumer : Consumer<?> in method public becameInactive(consumer Consumer<?>, partitionId int) : void in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Method | 8 | ||
| Move Method private handleProcessException(srcTopic String) : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to private handleProcessException(srcTopic String) : void from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Method private createConsumerConfiguration(topicName String) : ConsumerConfiguration from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to protected createConsumerConfiguration(topicName String) : ConsumerConfiguration from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Method public becameActive(consumer Consumer, partitionId int) : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to public becameActive(consumer Consumer<?>, partitionId int) : void from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Method private resubscribeTopicsIfNeeded() : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to private resubscribeTopicsIfNeeded() : void from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Method private addTopicToResubscribeList(topicName String) : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to private addTopicToResubscribeList(topicName String) : void from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Method private getSubscriptionType() : SubscriptionType from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to protected getSubscriptionType() : SubscriptionType from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Method public becameInactive(consumer Consumer, partitionId int) : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to public becameInactive(consumer Consumer<?>, partitionId int) : void from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Method private resubscribe(srcTopic String) : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to private resubscribe(srcTopic String) : void from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Attribute | 3 | ||
| Move Attribute private outputProducer : Producers from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to protected outputProducer : Producers from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Move Attribute private inputConsumers : Map<String,Consumer> from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to protected inputConsumers : Map<String,Consumer> from class org.apache.pulsar.functions.instance.processors.MessageProcessorBase | From | To | |
| Move Attribute private inputTopicsToResubscribe : LinkedList<String> from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to private inputTopicsToResubscribe : LinkedList<String> from class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor from class org.apache.pulsar.functions.instance.JavaInstanceRunnable | From | To | |
| Extract Method | 2 | ||
| Extract Method public createProducer(client PulsarClient, topic String) : Producer extracted from protected createProducer(topic String) : Producer in class org.apache.pulsar.functions.instance.producers.AbstractOneOuputTopicProducers | From | To | |
| Extract Method public createProducer(client PulsarClient, topic String, producerName String) : Producer extracted from protected createProducer(topic String, producerName String) : Producer in class org.apache.pulsar.functions.instance.producers.AbstractOneOuputTopicProducers | From | To |