Uses of Interface
org.springframework.pulsar.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.springframework.pulsar.spring.cloud.stream.binder
Constructors in org.springframework.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.springframework.pulsar.spring.cloud.stream.binder.config
Methods in org.springframework.pulsar.spring.cloud.stream.binder.config that return PulsarHeaderMapperMethods in org.springframework.pulsar.spring.cloud.stream.binder.config with parameters of type PulsarHeaderMapperModifier and TypeMethodDescriptionPulsarBinderConfiguration.pulsarMessageChannelBinder
(PulsarTopicProvisioner pulsarTopicProvisioner, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<byte[]> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, PulsarExtendedBindingProperties bindingConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper) -
Uses of PulsarHeaderMapper in org.springframework.pulsar.support.converter
Constructors in org.springframework.pulsar.support.converter with parameters of type PulsarHeaderMapper -
Uses of PulsarHeaderMapper in org.springframework.pulsar.support.header
Classes in org.springframework.pulsar.support.header that implement PulsarHeaderMapperModifier and TypeClassDescriptionclass
AbstractPulsarHeaderMapper<ToPulsarHeadersContextType,
ToSpringHeadersContextType> BasePulsarHeaderMapper
implementation that constrains which headers are mapped viaheader matchers
.class
APulsarHeaderMapper
implementation that writes headers as JSON.class
APulsarHeaderMapper
that converts header values using simple 'toString'.