Index

A B C D E F G H I J K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

T

TEMPLATE_OBSERVATION - Enum constant in enum class org.springframework.pulsar.observation.PulsarTemplateObservation
Observation created when a Pulsar template sends a message.
toMessage(Message<T>, Consumer<T>, Type) - Method in interface org.springframework.pulsar.support.converter.PulsarMessageConverter
 
toMessage(Message<V>, Consumer<V>, Type) - Method in class org.springframework.pulsar.support.converter.PulsarRecordMessageConverter
 
toMessageFromReader(Message<T>, Reader<T>, Type) - Method in interface org.springframework.pulsar.support.converter.PulsarMessageConverter
 
toMessagingMessage(Message<V>, Consumer<V>) - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
 
toMessagingMessageFromReader(Message<V>, Reader<V>) - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
 
toPatternString() - Method in class org.springframework.pulsar.support.header.PulsarHeaderMatcher.PatternMatch
 
TOPIC_NAME - Static variable in class org.springframework.pulsar.support.PulsarHeaders
Topic name.
topicName() - Method in record class org.springframework.pulsar.core.PulsarTopic
Returns the value of the topicName record component.
topicPattern() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
Topic patten to listen to.
topicPattern() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener
Topic patten to listen to.
TopicResolver - Interface in org.springframework.pulsar.core
Resolves topics to use when producing or consuming.
topics() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
Topics to listen to.
topics() - Element in annotation interface org.springframework.pulsar.annotation.PulsarReader
Topics to listen to.
topics() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener
Topics to listen to.
toPulsarHeaders(MessageHeaders) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
 
toPulsarHeaders(MessageHeaders) - Method in interface org.springframework.pulsar.support.header.PulsarHeaderMapper
Map from the given Spring Messaging headers to Pulsar message headers.
ToPulsarHeadersContext(Map<String, String>) - Constructor for record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToPulsarHeadersContext
Creates an instance of a ToPulsarHeadersContext record class.
toPulsarHeadersOnCompleted(MessageHeaders, Map<String, String>, JsonPulsarHeaderMapper.ToPulsarHeadersContext) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper
 
toPulsarHeadersOnCompleted(MessageHeaders, Map<String, String>, ToPulsarHeadersContextType) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
toPulsarHeadersOnStarted(MessageHeaders) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
toPulsarHeadersOnStarted(MessageHeaders) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper
 
toPulsarHeaderValue(String, Object, Object) - Method in class org.springframework.pulsar.support.header.ToStringPulsarHeaderMapper
 
toPulsarHeaderValue(String, Object, JsonPulsarHeaderMapper.ToPulsarHeadersContext) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper
 
toPulsarHeaderValue(String, Object, ToPulsarHeadersContextType) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
Determine the Pulsar header value to use for a Spring Messaging header.
toSpringHeaders(Message<?>) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
 
toSpringHeaders(Message<?>) - Method in interface org.springframework.pulsar.support.header.PulsarHeaderMapper
Map the headers from the given Pulsar message to Spring Messaging headers.
ToSpringHeadersContext(Map<String, String>) - Constructor for record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToSpringHeadersContext
Creates an instance of a ToSpringHeadersContext record class.
toSpringHeadersOnCompleted(Message<?>, MessageHeaders, ToSpringHeadersContextType) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
toSpringHeadersOnStarted(Message<?>) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
toSpringHeadersOnStarted(Message<?>) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper
 
toSpringHeaderValue(String, String, Object) - Method in class org.springframework.pulsar.support.header.ToStringPulsarHeaderMapper
 
toSpringHeaderValue(String, String, JsonPulsarHeaderMapper.ToSpringHeadersContext) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper
 
toSpringHeaderValue(String, String, ToSpringHeadersContextType) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
Determine the Spring Messaging header value to use for a Pulsar header.
toString() - Method in record class org.springframework.pulsar.core.PulsarTopic
Returns a string representation of this record class.
toString() - Method in class org.springframework.pulsar.event.ConsumerFailedToStartEvent
 
toString() - Method in class org.springframework.pulsar.event.ConsumerStartedEvent
 
toString() - Method in class org.springframework.pulsar.event.ConsumerStartingEvent
 
toString() - Method in class org.springframework.pulsar.event.ReaderFailedToStartEvent
 
toString() - Method in class org.springframework.pulsar.event.ReaderStartedEvent
 
toString() - Method in class org.springframework.pulsar.event.ReaderStartingEvent
 
toString() - Method in record class org.springframework.pulsar.function.PulsarFunction
Returns a string representation of this record class.
toString() - Method in record class org.springframework.pulsar.function.PulsarSink
Returns a string representation of this record class.
toString() - Method in record class org.springframework.pulsar.function.PulsarSource
Returns a string representation of this record class.
toString() - Method in class org.springframework.pulsar.listener.adapter.InvocationResult
 
toString() - Method in record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.NonTrustedHeaderType
Returns a string representation of this record class.
toString() - Method in record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToPulsarHeadersContext
Returns a string representation of this record class.
toString() - Method in record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToSpringHeadersContext
Returns a string representation of this record class.
toStringClasses(String...) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder
Add class names to the list of classes that should be serialized using their Object.toString() method.
ToStringPulsarHeaderMapper - Class in org.springframework.pulsar.support.header
A PulsarHeaderMapper that converts header values using simple 'toString'.
ToStringPulsarHeaderMapper() - Constructor for class org.springframework.pulsar.support.header.ToStringPulsarHeaderMapper
Construct a 'ToString' mapper that will match all inbound headers and all outbound headers (except internal framework headers and id/timestamp).
ToStringPulsarHeaderMapper(List<String>, List<String>) - Constructor for class org.springframework.pulsar.support.header.ToStringPulsarHeaderMapper
Construct a 'ToString' mapper that will match the supplied inbound and outbound patterns.
trusted(String) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper
 
trustedPackages(String...) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder
Add packages to the list of trusted packages used when constructing objects from JSON.
type() - Method in record class org.springframework.pulsar.function.PulsarFunction
 
type() - Method in interface org.springframework.pulsar.function.PulsarFunctionOperations
Gets the type of function the operations handles.
type() - Method in record class org.springframework.pulsar.function.PulsarSink
 
type() - Method in record class org.springframework.pulsar.function.PulsarSource
 
TypedMessageBuilderCustomizer<T> - Interface in org.springframework.pulsar.core
The interface to customize a TypedMessageBuilder.
A B C D E F G H I J K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form