Toggle navigation
Home
org.apache.pulsar.client.api.Consumer to org.apache.pulsar.client.api.Consumer<T>
No. of Instances - 21
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
PatternTopicsConsumerImpl
to
PatternTopicsConsumerImpl<>
Add or Remove Method invocation
lookup.getTopicsUnderNamespace(namespaceName).thenAccept(topics -> { if (log.isDebugEnabled()) { log.debug("Get topics under namespace {}, topics.size: {}",namespaceName.toString(),topics.size()); topics.forEach(topicName -> log.debug("Get topics under namespace {}, topic: {}",namespaceName.toString(),topicName)); } List<String> topicsList=topicsPatternFilter(topics,conf.getTopicsPattern()); conf.getTopicNames().addAll(topicsList); ConsumerBase consumer=new PatternTopicsConsumerImpl<>(conf.getTopicsPattern(),PulsarClientImpl.this,conf,externalExecutorProvider.getExecutor(),consumerSubscribedFuture); synchronized (consumers) { consumers.put(consumer,Boolean.TRUE); } } )
to
lookup.getTopicsUnderNamespace(namespaceName).thenAccept(topics -> { if (log.isDebugEnabled()) { log.debug("Get topics under namespace {}, topics.size: {}",namespaceName.toString(),topics.size()); topics.forEach(topicName -> log.debug("Get topics under namespace {}, topic: {}",namespaceName.toString(),topicName)); } List<String> topicsList=topicsPatternFilter(topics,conf.getTopicsPattern()); conf.getTopicNames().addAll(topicsList); ConsumerBase consumer=new PatternTopicsConsumerImpl<>(conf.getTopicsPattern(),PulsarClientImpl.this,conf,externalExecutorProvider.getExecutor(),consumerSubscribedFuture,schema); synchronized (consumers) { consumers.put(consumer,Boolean.TRUE); } } )
Update argument list (Method invocation)
subscribeAsync
to
subscribeAsync
patternTopicSubscribeAsync
to
patternTopicSubscribeAsync
multiTopicSubscribeAsync
to
multiTopicSubscribeAsync