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

O

objectMapper(ObjectMapper) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder

Sets the object mapper to use to read/write header values as JSON.

obtainResourceHolder(PulsarClient, Duration) - Static method in class org.springframework.pulsar.transaction.PulsarTransactionUtils

Obtain a resource holder that is synchronized with the current transaction.

of(T) - Static method in class org.springframework.pulsar.core.Resolved

Factory method to create a Resolved when resolution succeeds.

onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry

onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry

onEviction(K, V, String) - Method in interface org.springframework.pulsar.cache.provider.CacheProviderFactory.EvictionListener

Called when an entry is evicted from the cache.

ORDERING_KEY - Static variable in class org.springframework.pulsar.support.PulsarHeaders

Message ordering key.

orElseThrow() - Method in class org.springframework.pulsar.core.Resolved

Returns the resolved value if a value was resolved and no exception occurred, otherwise throws the resolution exception back to the caller.

orElseThrow(Supplier<String>) - Method in class org.springframework.pulsar.core.Resolved

Returns the resolved value if a value was resolved and no exception occurred, otherwise wraps the resolution exception with the provided error message and throws back to the caller.

org.springframework.pulsar - package org.springframework.pulsar

Package containing the Spring for Apache Pulsar framework classes.

org.springframework.pulsar.annotation - package org.springframework.pulsar.annotation

Package containing annotations used by the framework.

org.springframework.pulsar.aot - package org.springframework.pulsar.aot

Package containing AOT runtime hints used by the framework.

org.springframework.pulsar.cache.provider - package org.springframework.pulsar.cache.provider

org.springframework.pulsar.cache.provider.caffeine - package org.springframework.pulsar.cache.provider.caffeine

org.springframework.pulsar.config - package org.springframework.pulsar.config

Package containing Spring configuration classes for the framework.

org.springframework.pulsar.core - package org.springframework.pulsar.core

Package containing the core components of the framework.

org.springframework.pulsar.event - package org.springframework.pulsar.event

Package containing events produced by the framework.

org.springframework.pulsar.function - package org.springframework.pulsar.function

Package containing support for Pulsar Functions and Pulsar IO Connectors.

org.springframework.pulsar.listener - package org.springframework.pulsar.listener

Package containing listener components for receiving Pulsar messages.

org.springframework.pulsar.listener.adapter - package org.springframework.pulsar.listener.adapter

Package containing components for adapting Pulsar messages to message listeners.

org.springframework.pulsar.observation - package org.springframework.pulsar.observation

Package containing components that provide support for the Observation API.

org.springframework.pulsar.reactive.aot - package org.springframework.pulsar.reactive.aot

Package containing Reactive AOT runtime hints used by the framework.

org.springframework.pulsar.reactive.config - package org.springframework.pulsar.reactive.config

Package containing Spring configuration classes for the framework.

org.springframework.pulsar.reactive.config.annotation - package org.springframework.pulsar.reactive.config.annotation

Package containing annotations used by the framework.

org.springframework.pulsar.reactive.core - package org.springframework.pulsar.reactive.core

Package containing the core reactive components of the framework.

org.springframework.pulsar.reactive.listener - package org.springframework.pulsar.reactive.listener

Package containing listener components for receiving Pulsar messages.

org.springframework.pulsar.reactive.listener.adapter - package org.springframework.pulsar.reactive.listener.adapter

Package containing listener components for receiving Pulsar messages.

org.springframework.pulsar.reactive.support - package org.springframework.pulsar.reactive.support

Package containing support classes for processing Pulsar messages.

org.springframework.pulsar.reader - package org.springframework.pulsar.reader

org.springframework.pulsar.support - package org.springframework.pulsar.support

Package containing general support components.

org.springframework.pulsar.support.converter - package org.springframework.pulsar.support.converter

Package containing message converters.

org.springframework.pulsar.support.header - package org.springframework.pulsar.support.header

Package containing components to support Pulsar header functionality.

org.springframework.pulsar.transaction - package org.springframework.pulsar.transaction

Provides classes related to transactions.

outboundPatterns(String...) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder

Adds to the list of patterns to be used for outbound header matching.

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