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

E

EnablePulsar - Annotation Interface in org.springframework.pulsar.annotation

Enables detection of PulsarListener annotations on any Spring-managed bean in the container.

EnableReactivePulsar - Annotation Interface in org.springframework.pulsar.reactive.config.annotation

Enables detection of ReactivePulsarListener annotations on any Spring-managed bean in the container.

enforceStopPolicyOnUserDefinedFunctions() - Method in class org.springframework.pulsar.function.PulsarFunctionAdministration

Called during server shutdown, enforces the stop policy on all Pulsar functions that were successfully processed during server startup.

enhancedObjectMapper() - Static method in class org.springframework.pulsar.support.header.JacksonUtils

Factory for ObjectMapper instances with registered well-known modules and disabled MapperFeature.DEFAULT_VIEW_INCLUSION and DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES features.

equals(Object) - Method in record class org.springframework.pulsar.core.PulsarTopic

Indicates whether some other object is "equal to" this one.

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

equals(Object) - Method in record class org.springframework.pulsar.function.PulsarFunction

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.springframework.pulsar.function.PulsarSink

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.springframework.pulsar.function.PulsarSource

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.NonTrustedHeaderType

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToPulsarHeadersContext

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToSpringHeadersContext

Indicates whether some other object is "equal to" this one.

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

Event time (long).

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

Gets the exception that may have occurred during resolution.

EXCEPTION_THROWN_CAUSE - Static variable in class org.springframework.pulsar.listener.PulsarDeadLetterPublishingRecoverer

TODO: Move this to a common constants class.

executeInTransaction(PulsarTemplate.TemplateCallback<T, R>) - Method in class org.springframework.pulsar.core.PulsarTemplate

Execute some arbitrary operation(s) on the template and return the result.

expressionContext - Variable in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

ExpressionResolver - Interface in org.springframework.pulsar.core

Strategy interface for resolving a value from a string expression.

extractAndConvertValue(Message<V>) - Method in class org.springframework.pulsar.support.converter.PulsarRecordMessageConverter

extractMessageId(Message<T>) - Static method in class org.springframework.pulsar.reactive.support.MessageUtils

Determine the Pulsar MessageId for a given Spring message by extracting the value of its PulsarHeaders.MESSAGE_ID header.

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