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

C

Cache() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarProperties.Cache

Cache() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Cache

cachingPulsarProducerFactory(PulsarClient) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

CachingPulsarProducerFactory<T> - Class in org.springframework.pulsar.core

A PulsarProducerFactory that extends the default implementation by caching the created producers.

CachingPulsarProducerFactory(PulsarClient, Map<String, Object>, Duration, Long, Integer) - Constructor for class org.springframework.pulsar.core.CachingPulsarProducerFactory

Construct a caching producer factory with the specified values for the cache configuration.

clearMessage() - Method in class org.springframework.pulsar.listener.DefaultPulsarConsumerErrorHandler

clearMessage() - Method in interface org.springframework.pulsar.listener.PulsarConsumerErrorHandler

Clear the message in error from managing (such as resetting any thread state etc.).

Client() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarProperties.Client

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

Override the container factory's concurrency setting for this listener.

concurrency() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener

Override the container factory's concurrency setting for this listener.

ConcurrentPulsarListenerContainerFactory<T> - Class in org.springframework.pulsar.config

Concrete implementation for PulsarListenerContainerFactory.

ConcurrentPulsarListenerContainerFactory(PulsarConsumerFactory<? super T>, PulsarContainerProperties, ObservationRegistry) - Constructor for class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory

ConcurrentPulsarMessageListenerContainer<T> - Class in org.springframework.pulsar.listener

Creates a concurrent execution context of DefaultPulsarMessageListenerContainer instances based on the concurrency.

ConcurrentPulsarMessageListenerContainer(PulsarConsumerFactory<? super T>, PulsarContainerProperties, ObservationRegistry) - Constructor for class org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer

configureListenerAdapter(PulsarMessagingMessageListenerAdapter<V>) - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint

configureListenerAdapter(PulsarMessagingMessageListenerAdapter<V>) - Method in class org.springframework.pulsar.reactive.config.MethodReactivePulsarListenerEndpoint

configurePulsarListeners(PulsarListenerEndpointRegistrar) - Method in interface org.springframework.pulsar.annotation.PulsarListenerConfigurer

Callback allowing a PulsarListenerEndpointRegistry and specific PulsarListenerEndpoint instances to be registered against the given PulsarListenerEndpointRegistrar.

Consumer() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarProperties.Consumer

Consumer() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Consumer

ConsumerBuilderConfigurationUtil - Class in org.springframework.pulsar.core

Utility methods to help load configuration into a ConsumerBuilder.

ConsumerBuilderCustomizer<T> - Interface in org.springframework.pulsar.core

The interface to customize a ConsumerBuilder.

consumerCustomizer() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener

The bean name or a 'SpEL' expression that resolves to a ReactiveMessageConsumerBuilderCustomizer to use to configure the consumer.

ConsumerFailedToStartEvent - Class in org.springframework.pulsar.event

Event to publish when the consumer is failed to start.

ConsumerFailedToStartEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ConsumerFailedToStartEvent

Construct an instance with the provided source and container.

ConsumerStartedEvent - Class in org.springframework.pulsar.event

Event to publish when the consumer is started.

ConsumerStartedEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ConsumerStartedEvent

Construct an instance with the provided source and container.

ConsumerStartingEvent - Class in org.springframework.pulsar.event

Event to publish while the consumer is starting.

ConsumerStartingEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ConsumerStartingEvent

Construct an instance with the provided source and container.

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

The bean name of the PulsarListenerContainerFactory to use to create the message listener container responsible to serve this endpoint.

containerFactory() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener

The bean name of the ReactivePulsarListenerContainerFactory to use to create the message listener container responsible to serve this endpoint.

convert(Message<T>, Type, List<Exception>) - Method in class org.springframework.pulsar.support.converter.PulsarBatchMessagingMessageConverter

createConsumer(Schema<T>) - Method in class org.springframework.pulsar.core.DefaultPulsarConsumerFactory

createConsumer(Schema<T>) - Method in interface org.springframework.pulsar.core.PulsarConsumerFactory

Create a consumer.

createConsumer(Schema<T>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarConsumerFactory

createConsumer(Schema<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarConsumerFactory

Create a reactive message consumer.

createConsumer(Schema<T>, Collection<String>) - Method in class org.springframework.pulsar.core.DefaultPulsarConsumerFactory

createConsumer(Schema<T>, Collection<String>) - Method in interface org.springframework.pulsar.core.PulsarConsumerFactory

Create a consumer.

createConsumer(Schema<T>, Collection<String>, Map<String, String>, List<ConsumerBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.core.DefaultPulsarConsumerFactory

createConsumer(Schema<T>, Collection<String>, Map<String, String>, List<ConsumerBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.core.PulsarConsumerFactory

Create a consumer.

createConsumer(Schema<T>, List<ReactiveMessageConsumerBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarConsumerFactory

createConsumer(Schema<T>, List<ReactiveMessageConsumerBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarConsumerFactory

Create a reactive message consumer.

createContainer(String...) - Method in class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory

createContainer(String...) - Method in interface org.springframework.pulsar.config.ListenerContainerFactory

Create and configure a container without a listener; used to create containers that are not used for PulsarListener annotations.

createContainer(String...) - Method in class org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory

createContainerInstance(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory

createContainerInstance(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory

createContainerInstance(ReactivePulsarListenerEndpoint<T>) - Method in class org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory

createInstance() - Method in class org.springframework.pulsar.config.PulsarClientFactoryBean

createListenerContainer(E) - Method in interface org.springframework.pulsar.config.ListenerContainerFactory

Create a MessageListenerContainer for the given ListenerEndpoint.

createListenerContainer(E, ListenerContainerFactory<? extends C, E>) - Method in class org.springframework.pulsar.config.ListenerEndpointRegistry

createListenerContainer(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory

createListenerContainer(ReactivePulsarListenerEndpoint<T>) - Method in class org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory

createMessageHandler(ReactivePulsarMessageListenerContainer<T>, MessageConverter) - Method in class org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint

createMessageHandler(ReactivePulsarMessageListenerContainer<V>, MessageConverter) - Method in class org.springframework.pulsar.reactive.config.MethodReactivePulsarListenerEndpoint

createMessageListener(PulsarMessageListenerContainer, MessageConverter) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerEndpoint

createMessageListener(PulsarMessageListenerContainer, MessageConverter) - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint

createMessageListenerInstance(MessageConverter) - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint

createMessageListenerInstance(MessageConverter) - Method in class org.springframework.pulsar.reactive.config.MethodReactivePulsarListenerEndpoint

createOrModifyTopics(PulsarTopic...) - Method in class org.springframework.pulsar.core.PulsarAdministration

createOrModifyTopics(PulsarTopic...) - Method in interface org.springframework.pulsar.core.PulsarAdministrationOperations

Create or modify the given topics.

createProducer(Schema<T>) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

createProducer(Schema<T>) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory

Create a producer.

createProducer(Schema<T>, String) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

createProducer(Schema<T>, String) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory

Create a producer.

createProducer(Schema<T>, String, Collection<String>, List<ProducerBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

createProducer(Schema<T>, String, Collection<String>, List<ProducerBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory

Create a producer.

createReader(Schema<T>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarReaderFactory

createReader(Schema<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarReaderFactory

Create a reactive message reader.

createReader(Schema<T>, List<ReactiveMessageReaderBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarReaderFactory

createReader(Schema<T>, List<ReactiveMessageReaderBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarReaderFactory

Create a reactive message reader.

createSender(String, Schema<T>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory

createSender(String, Schema<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarSenderFactory

Create a reactive message sender.

createSender(String, Schema<T>, List<ReactiveMessageSenderBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory

createSender(String, Schema<T>, List<ReactiveMessageSenderBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarSenderFactory

Create a reactive message sender.

currentMessage() - Method in class org.springframework.pulsar.listener.DefaultPulsarConsumerErrorHandler

currentMessage() - Method in interface org.springframework.pulsar.listener.PulsarConsumerErrorHandler

Returns the current message in error.

customize(ConsumerBuilder<T>) - Method in interface org.springframework.pulsar.core.ConsumerBuilderCustomizer

Customizes a ConsumerBuilder.

customize(ProducerBuilder<T>) - Method in interface org.springframework.pulsar.core.ProducerBuilderCustomizer

Customizes a ProducerBuilder.

customize(TypedMessageBuilder<T>) - Method in interface org.springframework.pulsar.core.TypedMessageBuilderCustomizer

Customizes a TypedMessageBuilder.

customize(MessageSpecBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.MessageSpecBuilderCustomizer

Customizes a MessageSpecBuilder.

customize(ReactiveMessageConsumerBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactiveMessageConsumerBuilderCustomizer

Customizes a ReactiveMessageConsumerBuilder.

customize(ReactiveMessageReaderBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactiveMessageReaderBuilderCustomizer

Customizes a ReactiveMessageReaderBuilder.

customize(ReactiveMessageSenderBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactiveMessageSenderBuilderCustomizer

Customizes a ReactiveMessageSenderBuilder.

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