Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
B
- batch() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
-
Activate batch consumption.
- BATCH - Enum constant in enum class org.springframework.pulsar.listener.AckMode
-
Batch ack mode.
- BEAN_NAME - Enum constant in enum class org.springframework.pulsar.observation.PulsarTemplateObservation.TemplateLowCardinalityTags
-
Bean name of the template that sent the message.
- beanRef() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
-
A pseudo bean name used in SpEL expressions within this annotation to reference the current bean within which this listener is defined.
- beanRef() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener
-
A pseudo bean name used in SpEL expressions within this annotation to reference the current bean within which this listener is defined.
- boundedElastic - Enum constant in enum class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.SchedulerType
-
The reactor.core.scheduler.BoundedElasticScheduler.
- BROKER_PUBLISH_TIME - Static variable in class org.springframework.pulsar.support.PulsarHeaders
-
Broker publish time (long).
- build() - Method in class org.springframework.pulsar.core.PulsarTopicBuilder
-
Constructs the
PulsarTopic
with the properties configured in this builder. - buildAdminProperties() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties
- buildClientProperties() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties
- buildConsumerProperties() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties
- builder(String) - Static method in record class org.springframework.pulsar.core.PulsarTopic
- buildProducerProperties() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties
- buildProperties() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Admin
- buildProperties() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Client
- buildProperties() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Consumer
- buildProperties() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Producer
- buildReactiveMessageConsumerSpec() - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties
- buildReactiveMessageConsumerSpec() - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Consumer
- buildReactiveMessageReaderSpec() - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties
- buildReactiveMessageReaderSpec() - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Reader
- buildReactiveMessageSenderSpec() - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties
- buildReactiveMessageSenderSpec() - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Sender
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form