Uses of Interface
org.springframework.pulsar.core.TopicResolver
Packages that use TopicResolver
Package
Description
Package containing the Spring Boot
AutoConfiguration for the Spring for
Apache Pulsar framework.Package containing the core components of the framework.
Package containing listener components for receiving Pulsar messages.
Package containing the core reactive components of the framework.
Package containing listener components for receiving Pulsar messages.
-
Uses of TopicResolver in org.springframework.pulsar.autoconfigure
Methods in org.springframework.pulsar.autoconfigure with parameters of type TopicResolverModifier and TypeMethodDescriptionPulsarAutoConfiguration.cachingPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, TopicResolver topicResolver) PulsarAutoConfiguration.pulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, TopicResolver topicResolver) PulsarReactiveAutoConfiguration.pulsarReactiveTemplate(ReactivePulsarSenderFactory<?> reactivePulsarSenderFactory, SchemaResolver schemaResolver, TopicResolver topicResolver) PulsarAutoConfiguration.pulsarTemplate(PulsarProducerFactory<?> pulsarProducerFactory, ObjectProvider<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptorsProvider, SchemaResolver schemaResolver, TopicResolver topicResolver, ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistryProvider, ObjectProvider<PulsarTemplateObservationConvention> observationConventionProvider) PulsarReactiveAutoConfiguration.reactivePulsarSenderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient, ObjectProvider<org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache> cache, TopicResolver topicResolver) -
Uses of TopicResolver in org.springframework.pulsar.core
Classes in org.springframework.pulsar.core that implement TopicResolverModifier and TypeClassDescriptionclassTopic resolver that accepts custom type to topic mappings and uses the mappings during topic resolution.Constructors in org.springframework.pulsar.core with parameters of type TopicResolverModifierConstructorDescriptionCachingPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, Map<String, Object> producerConfig, TopicResolver topicResolver, Duration cacheExpireAfterAccess, Long cacheMaximumSize, Integer cacheInitialCapacity) Construct a caching producer factory with the specified values for the cache configuration.DefaultPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, Map<String, Object> config, TopicResolver topicResolver) PulsarTemplate(PulsarProducerFactory<T> producerFactory, List<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors, SchemaResolver schemaResolver, TopicResolver topicResolver, io.micrometer.observation.ObservationRegistry observationRegistry, PulsarTemplateObservationConvention observationConvention) Construct a template instance with optional observation configuration. -
Uses of TopicResolver in org.springframework.pulsar.listener
Methods in org.springframework.pulsar.listener that return TopicResolverMethods in org.springframework.pulsar.listener with parameters of type TopicResolverModifier and TypeMethodDescriptionvoidPulsarContainerProperties.setTopicResolver(TopicResolver topicResolver) -
Uses of TopicResolver in org.springframework.pulsar.reactive.core
Constructors in org.springframework.pulsar.reactive.core with parameters of type TopicResolverModifierConstructorDescriptionDefaultReactivePulsarSenderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec reactiveMessageSenderSpec, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache reactiveMessageSenderCache, TopicResolver topicResolver) ReactivePulsarTemplate(ReactivePulsarSenderFactory<T> reactiveMessageSenderFactory, SchemaResolver schemaResolver, TopicResolver topicResolver) Construct a template instance with a custom schema resolver and a custom topic resolver. -
Uses of TopicResolver in org.springframework.pulsar.reactive.listener
Methods in org.springframework.pulsar.reactive.listener that return TopicResolverMethods in org.springframework.pulsar.reactive.listener with parameters of type TopicResolverModifier and TypeMethodDescriptionvoidReactivePulsarContainerProperties.setTopicResolver(TopicResolver topicResolver)