6b205160c339bc941a5d3f36a9d2ee6f2bd26823
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 1 | ||
| Change Return Type OrderedScheduler to OrderedExecutor in method public getTopicOrderedExecutor() : OrderedExecutor in class org.apache.pulsar.broker.service.BrokerService | From | To | |
| Inline Variable | 2 | ||
| Inline Variable totalBytesSent : long in method public readEntriesComplete(entries List<Entry>, obj Object) : void from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer | From | To | |
| Inline Variable totalMessagesSent : long in method public readEntriesComplete(entries List<Entry>, obj Object) : void from class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer | From | To | |
| Extract Method | 5 | ||
| Extract Method public sendMessages(entries List<Entry>, listener SendListener) : SendMessageInfo extracted from public sendMessages(entries List<Entry>) : SendMessageInfo in class org.apache.pulsar.broker.service.Consumer | From | To | |
| Extract Method private internalReadEntriesFailed(exception ManagedLedgerException, ctx Object) : void extracted from public readEntriesFailed(exception ManagedLedgerException, ctx Object) : void in class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer | From | To | |
| Extract Method public internalReadEntriesComplete(entries List<Entry>, obj Object) : void extracted from public readEntriesComplete(entries List<Entry>, obj Object) : void in class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer | From | To | |
| Extract Method private internalRedeliverUnacknowledgedMessages(consumer Consumer) : void extracted from public redeliverUnacknowledgedMessages(consumer Consumer) : void in class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer | From | To | |
| Extract Method private internalConsumerFlow(consumer Consumer, additionalNumberOfMessages int) : void extracted from public consumerFlow(consumer Consumer, additionalNumberOfMessages int) : void in class org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type topicOrderedExecutor : OrderedScheduler to topicOrderedExecutor : OrderedExecutor in class org.apache.pulsar.broker.service.BrokerService | From | To | |
| Change Attribute Type configRegisteredListeners : ConcurrentOpenHashMap<String,Consumer> to configRegisteredListeners : ConcurrentOpenHashMap<String,Consumer<?>> in class org.apache.pulsar.broker.service.BrokerService | From | To | |
| Change Attribute Type executor : OrderedScheduler to executor : OrderedExecutor in class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic | From | To |