Uses of Interface
org.apache.pulsar.spring.support.header.PulsarHeaderMapper
Packages that use PulsarHeaderMapper
Package
Description
Package containing Spring Cloud Stream binder classes for Apache Pulsar.
Package containing message converters.
Package containing components to support Pulsar header functionality.
-
Uses of PulsarHeaderMapper in org.apache.pulsar.spring.cloud.stream.binder
Constructors in org.apache.pulsar.spring.cloud.stream.binder with parameters of type PulsarHeaderMapperModifierConstructorDescriptionPulsarMessageChannelBinder(PulsarTopicProvisioner provisioningProvider, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<?> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper) -
Uses of PulsarHeaderMapper in org.apache.pulsar.spring.cloud.stream.binder.config
Methods in org.apache.pulsar.spring.cloud.stream.binder.config that return PulsarHeaderMapperMethods in org.apache.pulsar.spring.cloud.stream.binder.config with parameters of type PulsarHeaderMapperModifier and TypeMethodDescriptionPulsarBinderConfiguration.pulsarMessageChannelBinder(PulsarTopicProvisioner pulsarTopicProvisioner, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<?> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, PulsarExtendedBindingProperties bindingConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper) -
Uses of PulsarHeaderMapper in org.apache.pulsar.spring.support.converter
Constructors in org.apache.pulsar.spring.support.converter with parameters of type PulsarHeaderMapper -
Uses of PulsarHeaderMapper in org.apache.pulsar.spring.support.header
Classes in org.apache.pulsar.spring.support.header that implement PulsarHeaderMapperModifier and TypeClassDescriptionclassAbstractPulsarHeaderMapper<ToPulsarHeadersContextType, ToSpringHeadersContextType>BasePulsarHeaderMapperimplementation that constrains which headers are mapped viaheader matchers.classAPulsarHeaderMapperimplementation that writes headers as JSON.classAPulsarHeaderMapperthat converts header values using simple 'toString'.