Toggle navigation
Home
org.apache.pulsar.client.api.Consumer to org.apache.pulsar.client.api.Consumer<byte[]>
No. of Instances - 59
No. of Commits - 3
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
consumer.acknowledgeAsync(message)
to
acknowledgeAsync
sharedPulsarClient.getSharedConsumer(pulsarSpoutConf.getTopic(),pulsarSpoutConf.getSubscriptionName(),consumerConf)
to
sharedPulsarClient.getSharedConsumer(consumerConf)
sharedPulsarClient.getClient().subscribe(pulsarSpoutConf.getTopic(),pulsarSpoutConf.getSubscriptionName(),consumerConf)
to
sharedPulsarClient.getClient().subscribeAsync(consumerConf).join()
consumers.add(pulsarClient.subscribe(topicName,"mysub",consumerConfig))
to
consumers.add(pulsarClient.newConsumer().topic(topicName).subscriptionName("mysub").subscriptionType(SubscriptionType.Shared).subscribe())
successfulConsumers.add(pulsarClient.subscribe(topicName,"mysub",consumerConfig))
to
successfulConsumers.add(pulsarClient.newConsumer().topic(topicName).subscriptionName("mysub").subscriptionType(SubscriptionType.Shared).subscribe())
Cascading Type Change (Different)
PartitionedConsumerImpl
to
PartitionedConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<byte[]>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<byte[]>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<byte[]>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<?>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
TopicsConsumerImpl
to
TopicsConsumerImpl<byte[]>
Cascading Type Change (Similar)
org.apache.pulsar.client.api.Consumer
to
org.apache.pulsar.client.api.Consumer<byte[]>