Index

A B C D E F G H I J L M N O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

C

Cache() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarProperties.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.

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

Concrete implementation for PulsarListenerContainerFactory.

ConcurrentPulsarListenerContainerFactory() - 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) - Constructor for class org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer

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

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

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.

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

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

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

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

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

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

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

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

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

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

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

createListenerContainer(PulsarListenerEndpoint) - Method in interface org.springframework.pulsar.config.PulsarListenerContainerFactory

createListenerContainer(PulsarListenerEndpoint, PulsarListenerContainerFactory<?>) - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistry

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

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(String, Schema<T>) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

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

Create a producer.

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

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

Create a producer.

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

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

Create a producer.

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

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

Create a producer.

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(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.

A B C D E F G H I J L M N O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form