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, Consumer, Type) - Method in interface org.springframework.pulsar.support.converter.PulsarMessageConverter

toMessage(Message, Consumer, Type) - Method in class org.springframework.pulsar.support.converter.PulsarRecordMessageConverter

toMessageFromReader(Message, Reader, Type) - Method in interface org.springframework.pulsar.support.converter.PulsarMessageConverter

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

toMessagingMessage(Message, Consumer) - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

toMessagingMessageFromReader(Message, Reader) - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

toPatternString() - Method in class org.springframework.pulsar.support.header.PulsarHeaderMatcher.PatternMatch

topic() - Element in annotation interface org.springframework.pulsar.annotation.PulsarMessage

Default topic for the annotated message class.

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.

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.

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) - Constructor for record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToPulsarHeadersContext

Creates an instance of a ToPulsarHeadersContext record class.

toPulsarHeadersOnCompleted(MessageHeaders, Map, ToPulsarHeadersContextType) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper

Called at the end of a successful AbstractPulsarHeaderMapper.toSpringHeaders(Message) invocation.

toPulsarHeadersOnCompleted(MessageHeaders, Map, JsonPulsarHeaderMapper.ToPulsarHeadersContext) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper

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

Called at the beginning of every AbstractPulsarHeaderMapper.toPulsarHeaders(MessageHeaders) invocation and the returned value is passed into each AbstractPulsarHeaderMapper.toPulsarHeaderValue(String, Object, ToPulsarHeadersContextType) invocation as well as the final AbstractPulsarHeaderMapper.toPulsarHeadersOnCompleted(MessageHeaders, Map, ToPulsarHeadersContextType).

toPulsarHeadersOnStarted(MessageHeaders) - 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.

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

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) - 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(MessageHeaders) invocation.

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

Called at the beginning of every AbstractPulsarHeaderMapper.toSpringHeaders(Message) invocation and the returned value is passed into each AbstractPulsarHeaderMapper.toSpringHeaderValue(String, String, ToSpringHeadersContextType) invocation as well as the final AbstractPulsarHeaderMapper.toSpringHeadersOnCompleted(Message, MessageHeaders, ToSpringHeadersContextType).

toSpringHeadersOnStarted(Message) - 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.

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

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.core.Resolved

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.

toString() - Method in class org.springframework.pulsar.transaction.PulsarResourceHolder

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, List) - Constructor for class org.springframework.pulsar.support.header.ToStringPulsarHeaderMapper

Construct a 'ToString' mapper that will match the supplied inbound and outbound patterns.

transactional() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener

Whether this listener should execute in a transaction.

TransactionProperties - Class in org.springframework.pulsar.core

Common transaction settings for components.

TransactionProperties() - Constructor for class org.springframework.pulsar.core.TransactionProperties

transactions() - Method in class org.springframework.pulsar.core.PulsarTemplate

Gets the transaction properties.

transactions() - Method in class org.springframework.pulsar.listener.PulsarContainerProperties

Gets the transaction settings for the listener container.

TransactionSettings() - Constructor for class org.springframework.pulsar.listener.PulsarContainerProperties.TransactionSettings

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