26c462625483ef0e0fa3c74bca6e84a3f569115b
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Push Down Method | 2 | ||
| Push Down Method private fetchSingleMessageFromBroker() : Message<T> from class org.apache.pulsar.client.impl.ConsumerImpl to private fetchSingleMessageFromBroker() : Message<T> from class org.apache.pulsar.client.impl.ZeroQueueConsumerImpl | From | To | |
| Push Down Method private triggerZeroQueueSizeListener(message Message<T>) : void from class org.apache.pulsar.client.impl.ConsumerImpl to private triggerZeroQueueSizeListener(message Message<T>) : void from class org.apache.pulsar.client.impl.ZeroQueueConsumerImpl | From | To | |
| Extract Subclass | 1 | ||
| Extract Subclass org.apache.pulsar.client.impl.ZeroQueueConsumerImpl from class org.apache.pulsar.client.impl.ConsumerImpl | From | To | |
| Push Down Attribute | 1 | ||
| Push Down Attribute private waitingOnReceiveForZeroQueueSize : boolean from class org.apache.pulsar.client.impl.ConsumerImpl to private waitingOnReceiveForZeroQueueSize : boolean from class org.apache.pulsar.client.impl.ZeroQueueConsumerImpl | From | To | |
| Extract Method | 2 | ||
| Extract Method protected consumerIsReconnectedToBroker(cnx ClientCnx, currentQueueSize int) : void extracted from public connectionOpened(cnx ClientCnx) : void in class org.apache.pulsar.client.impl.ConsumerImpl | From | To | |
| Extract Method protected triggerListener(numMessages int) : void extracted from package messageReceived(messageId MessageIdData, redeliveryCount int, headersAndPayload ByteBuf, cnx ClientCnx) : void in class org.apache.pulsar.client.impl.ConsumerImpl | From | To |