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> BasePulsarHeaderMapper
implementation that constrains which headers are mapped viaheader matchers
.The utilities for JacksonObjectMapper
instances.APulsarHeaderMapper
implementation 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 MessagingMessageHeaders
to 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.APulsarHeaderMapper
that converts header values using simple 'toString'.