|
Change Parameter Type dispatcherName : String to subscription : Subscription in method public NonPersistentDispatcherMultipleConsumers(topic NonPersistentTopic, subscription Subscription) in class org.apache.pulsar.broker.service.nonpersistent.NonPersistentDispatcherMultipleConsumers |
From |
To |
|
Change Parameter Type subscription : String to subscription : Subscription in method public getBatchSizeforEntry(metadataAndPayload ByteBuf, subscription Subscription, consumerId long) : int in class org.apache.pulsar.broker.service.Consumer |
From |
To |
|
Change Parameter Type subName : String to subscription : Subscription in method public NonPersistentDispatcherSingleActiveConsumer(subscriptionType SubType, partitionIndex int, topic NonPersistentTopic, subscription Subscription) in class org.apache.pulsar.broker.service.nonpersistent.NonPersistentDispatcherSingleActiveConsumer |
From |
To |