7a92111fe7824d422d1739abd06d85955b652212
Files Diff
- Added: 5
- Removed: 0
- Renamed: 0
- Modified: 22
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Variable | 3 | ||
| Extract Variable invalidMessageException : PulsarClientException.InvalidMessageException in method public sendAsync(message Message<T>, callback SendCallback) : void from class org.apache.pulsar.client.impl.ProducerImpl | From | To | |
| Extract Variable exception : PulsarClientException in method protected doAcknowledge(messageId MessageId, ackType AckType, properties Map<String,Long>) : CompletableFuture<Void> from class org.apache.pulsar.client.impl.ConsumerImpl | From | To | |
| Extract Method | 1 | ||
| Extract Method public createProducerAsync(conf ProducerConfigurationData, schema Schema<T>, interceptors ProducerInterceptors<T>) : CompletableFuture<Producer<T>> extracted from public createProducerAsync(conf ProducerConfigurationData, schema Schema<T>) : CompletableFuture<Producer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl | From | To | |
| Extract And Move Method | 3 | ||
| Extract And Move Method protected beforeConsume(message Message<T>) : Message<T> extracted from protected internalReceive() : Message<T> in class org.apache.pulsar.client.impl.ConsumerImpl & moved to class org.apache.pulsar.client.impl.ConsumerBase | From | To | |
| Extract And Move Method protected beforeConsume(message Message<T>) : Message<T> extracted from protected internalReceiveAsync() : CompletableFuture<Message<T>> in class org.apache.pulsar.client.impl.ConsumerImpl & moved to class org.apache.pulsar.client.impl.ConsumerBase | From | To | |
| Extract And Move Method protected beforeConsume(message Message<T>) : Message<T> extracted from protected internalReceive(timeout int, unit TimeUnit) : Message<T> in class org.apache.pulsar.client.impl.ConsumerImpl & moved to class org.apache.pulsar.client.impl.ConsumerBase | From | To |