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() - Constructor for class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Template

TEMPLATE_OBSERVATION - Enum constant in enum class org.apache.pulsar.spring.observation.PulsarTemplateObservation

Observation created when a Pulsar template sends a message.

Threads() - Constructor for class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Threads

toAllConsumerPropertiesMap() - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

Gets a map representation of base and extended consumer properties.

toAllProducerPropertiesMap() - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

Gets a map representation of base and extended producer properties.

toBaseConsumerPropertiesMap() - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

Gets a map representation of the base consumer properties (those defined in parent class).

toBaseProducerPropertiesMap() - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

Gets a map representation of the base producer properties (those defined in parent class).

toExtendedConsumerPropertiesMap() - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

Gets a map representation of the extended consumer properties (those defined in this class).

toExtendedProducerPropertiesMap() - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

Gets a map representation of the extended producer properties (those defined in this class).

toMessage(Message, Consumer, Type) - Method in interface org.apache.pulsar.spring.support.converter.PulsarMessageConverter

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

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

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

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

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

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

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

Default topic for the annotated message class.

Topic() - Constructor for class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.Topic

TOPIC_NAME - Static variable in class org.apache.pulsar.spring.support.PulsarHeaders

Topic name.

topicName() - Method in record class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.TypeMapping

Returns the value of the topicName record component.

topicName() - Method in record class org.apache.pulsar.spring.core.PulsarTopic

Returns the value of the topicName record component.

topicPattern() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarListener

Topic patten to listen to.

TopicResolver - Interface in org.apache.pulsar.spring.core

Resolves topics to use when producing or consuming.

topics() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarListener

Topics to listen to.

topics() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarReader

Topics to listen to.

toPulsarHeaders(MessageHeaders) - Method in class org.apache.pulsar.spring.support.header.AbstractPulsarHeaderMapper

toPulsarHeaders(MessageHeaders) - Method in interface org.apache.pulsar.spring.support.header.PulsarHeaderMapper

Map from the given Spring Messaging headers to Pulsar message headers.

ToPulsarHeadersContext(Map) - Constructor for record class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.ToPulsarHeadersContext

Creates an instance of a ToPulsarHeadersContext record class.

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

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

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

toPulsarHeadersOnStarted(MessageHeaders) - Method in class org.apache.pulsar.spring.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.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper

toPulsarHeaderValue(String, Object, ToPulsarHeadersContextType) - Method in class org.apache.pulsar.spring.support.header.AbstractPulsarHeaderMapper

Determine the Pulsar header value to use for a Spring Messaging header.

toPulsarHeaderValue(String, Object, Object) - Method in class org.apache.pulsar.spring.support.header.ToStringPulsarHeaderMapper

toPulsarHeaderValue(String, Object, JsonPulsarHeaderMapper.ToPulsarHeadersContext) - Method in class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper

toSpringHeaders(Message) - Method in class org.apache.pulsar.spring.support.header.AbstractPulsarHeaderMapper

toSpringHeaders(Message) - Method in interface org.apache.pulsar.spring.support.header.PulsarHeaderMapper

Map the headers from the given Pulsar message to Spring Messaging headers.

ToSpringHeadersContext(Map) - Constructor for record class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.ToSpringHeadersContext

Creates an instance of a ToSpringHeadersContext record class.

toSpringHeadersOnCompleted(Message, MessageHeaders, ToSpringHeadersContextType) - Method in class org.apache.pulsar.spring.support.header.AbstractPulsarHeaderMapper

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

toSpringHeadersOnStarted(Message) - Method in class org.apache.pulsar.spring.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.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper

toSpringHeaderValue(String, String, ToSpringHeadersContextType) - Method in class org.apache.pulsar.spring.support.header.AbstractPulsarHeaderMapper

Determine the Spring Messaging header value to use for a Pulsar header.

toSpringHeaderValue(String, String, Object) - Method in class org.apache.pulsar.spring.support.header.ToStringPulsarHeaderMapper

toSpringHeaderValue(String, String, JsonPulsarHeaderMapper.ToSpringHeadersContext) - Method in class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper

toString() - Method in record class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.SchemaInfo

Returns a string representation of this record class.

toString() - Method in record class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.TypeMapping

Returns a string representation of this record class.

toString() - Method in record class org.apache.pulsar.spring.core.PulsarTopic

Returns a string representation of this record class.

toString() - Method in class org.apache.pulsar.spring.core.Resolved

toString() - Method in class org.apache.pulsar.spring.event.ConsumerFailedToStartEvent

toString() - Method in class org.apache.pulsar.spring.event.ConsumerStartedEvent

toString() - Method in class org.apache.pulsar.spring.event.ConsumerStartingEvent

toString() - Method in class org.apache.pulsar.spring.event.ReaderFailedToStartEvent

toString() - Method in class org.apache.pulsar.spring.event.ReaderStartedEvent

toString() - Method in class org.apache.pulsar.spring.event.ReaderStartingEvent

toString() - Method in record class org.apache.pulsar.spring.function.PulsarFunction

Returns a string representation of this record class.

toString() - Method in record class org.apache.pulsar.spring.function.PulsarSink

Returns a string representation of this record class.

toString() - Method in record class org.apache.pulsar.spring.function.PulsarSource

Returns a string representation of this record class.

toString() - Method in class org.apache.pulsar.spring.listener.adapter.InvocationResult

toString() - Method in record class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.NonTrustedHeaderType

Returns a string representation of this record class.

toString() - Method in record class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.ToPulsarHeadersContext

Returns a string representation of this record class.

toString() - Method in record class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.ToSpringHeadersContext

Returns a string representation of this record class.

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

toStringClasses(String...) - Method in class org.apache.pulsar.spring.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.apache.pulsar.spring.support.header

A PulsarHeaderMapper that converts header values using simple 'toString'.

ToStringPulsarHeaderMapper() - Constructor for class org.apache.pulsar.spring.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.apache.pulsar.spring.support.header.ToStringPulsarHeaderMapper

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

Transaction() - Constructor for class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Transaction

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

Whether this listener should execute in a transaction.

TransactionProperties - Class in org.apache.pulsar.spring.core

Common transaction settings for components.

TransactionProperties() - Constructor for class org.apache.pulsar.spring.core.TransactionProperties

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

Gets the transaction properties.

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

Gets the transaction settings for the listener container.

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

trusted(String) - Method in class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper

Determines whether a type is trusted for JSON deserialization.

trustedPackages(String...) - Method in class org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder

Add packages to the trusted list used when deserializing JSON header values.

trustedPackages(BeanFactory) - Static method in class org.apache.pulsar.spring.annotation.PulsarHeaderObjectMapperUtils

Gets the optional trusted packages to use when deserializing JSON header values.

type() - Method in record class org.apache.pulsar.spring.function.PulsarFunction

type() - Method in interface org.apache.pulsar.spring.function.PulsarFunctionOperations

Gets the type of function the operations handles.

type() - Method in record class org.apache.pulsar.spring.function.PulsarSink

type() - Method in record class org.apache.pulsar.spring.function.PulsarSource

TypedMessageBuilderCustomizer<T> - Interface in org.apache.pulsar.spring.core

The interface to customize a TypedMessageBuilder.

TypeMapping(Class, String, PulsarProperties.Defaults.SchemaInfo) - Constructor for record class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.TypeMapping

Creates an instance of a TypeMapping record class.

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