|
Push Down Method public addAcknowledgment(msgId MessageIdImpl, ackType AckType, properties Map<String,Long>) : void from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to public addAcknowledgment(msgId MessageIdImpl, ackType AckType, properties Map<String,Long>) : void from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Method public flush() : void from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to public flush() : void from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Method public isDuplicate(messageId MessageId) : boolean from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to public isDuplicate(messageId MessageId) : boolean from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Method private doCumulativeAck(msgId MessageIdImpl) : void from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to private doCumulativeAck(msgId MessageIdImpl) : void from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Method public AcknowledgmentsGroupingTracker(consumer ConsumerImpl<?>, conf ConsumerConfigurationData<?>, eventLoopGroup EventLoopGroup) from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to public PersistentAcknowledgmentsGroupingTracker(consumer ConsumerImpl<?>, conf ConsumerConfigurationData<?>, eventLoopGroup EventLoopGroup) from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Method public close() : void from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to public close() : void from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Method private doImmediateAck(msgId MessageIdImpl, ackType AckType, properties Map<String,Long>) : boolean from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to private doImmediateAck(msgId MessageIdImpl, ackType AckType, properties Map<String,Long>) : boolean from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Attribute private consumer : ConsumerImpl<?> from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to private consumer : ConsumerImpl<?> from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Attribute private acknowledgementGroupTimeMicros : long from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to private acknowledgementGroupTimeMicros : long from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Attribute private MAX_ACK_GROUP_SIZE : int from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to private MAX_ACK_GROUP_SIZE : int from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Attribute private pendingIndividualAcks : ConcurrentSkipListSet<MessageIdImpl> from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to private pendingIndividualAcks : ConcurrentSkipListSet<MessageIdImpl> from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Attribute private lastCumulativeAck : MessageIdImpl from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to private lastCumulativeAck : MessageIdImpl from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |
|
Push Down Attribute private scheduledTask : ScheduledFuture<?> from class org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker to private scheduledTask : ScheduledFuture<?> from class org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker |
From |
To |