Package org.springframework.pulsar.support.header
@NonNullApi
@NonNullFields
package org.springframework.pulsar.support.header
Package containing components to support Pulsar header functionality.
-
ClassDescriptionAbstractPulsarHeaderMapper<ToPulsarHeadersContextType,
ToSpringHeadersContextType> BasePulsarHeaderMapperimplementation that constrains which headers are mapped viaheader matchers.The utilities for JacksonObjectMapperinstances.APulsarHeaderMapperimplementation that writes headers as JSON.Represents a header that could not be decoded due to an untrusted type.Context used forAbstractPulsarHeaderMapper.toPulsarHeaders(org.springframework.messaging.MessageHeaders)(outbound) that includes the cumulative map of header name to classname for headers that are serialized with JSON.Context used forAbstractPulsarHeaderMapper.toSpringHeaders(org.apache.pulsar.client.api.Message<?>)(inbound) that includes the cumulative map of header name to classname for headers in the incoming message that were serialized with JSON.Defines the contract for mapping Spring MessagingMessageHeadersto and from Pulsar message headers.Defines the contract for matching message headers.A matcher that never matches a set of headers.A pattern-based header matcher that matches if the specified header matches the specified simple pattern.APulsarHeaderMapperthat converts header values using simple 'toString'.