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

toMessageFromReader(Message<V>, Reader<V>, Type) - Method in class org.springframework.pulsar.support.converter.PulsarRecordMessageConverter

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

Called at the end of a successful AbstractPulsarHeaderMapper.toSpringHeaders(org.apache.pulsar.client.api.Message<?>) invocation.

toPulsarHeadersOnStarted(MessageHeaders) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper

Called at the beginning of every AbstractPulsarHeaderMapper.toPulsarHeaders(org.springframework.messaging.MessageHeaders) invocation and the returned value is passed into each AbstractPulsarHeaderMapper.toPulsarHeaderValue(java.lang.String, java.lang.Object, ToPulsarHeadersContextType) invocation as well as the final AbstractPulsarHeaderMapper.toPulsarHeadersOnCompleted(org.springframework.messaging.MessageHeaders, java.util.Map<java.lang.String, java.lang.String>, ToPulsarHeadersContextType).

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

Called at the end of a successful AbstractPulsarHeaderMapper.toPulsarHeaders(org.springframework.messaging.MessageHeaders) invocation.

toSpringHeadersOnStarted(Message<?>) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper

Called at the beginning of every AbstractPulsarHeaderMapper.toSpringHeaders(org.apache.pulsar.client.api.Message<?>) invocation and the returned value is passed into each AbstractPulsarHeaderMapper.toSpringHeaderValue(java.lang.String, java.lang.String, ToSpringHeadersContextType) invocation as well as the final AbstractPulsarHeaderMapper.toSpringHeadersOnCompleted(org.apache.pulsar.client.api.Message<?>, org.springframework.messaging.MessageHeaders, ToSpringHeadersContextType).

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