See: Description
| Interface | Description |
|---|---|
| MessageListenerResolver |
Provides flexibility to implement
MessageListener as beans
while still being able to override default listener resolver for Pulsar Consumers. |
| TenantNameResolver |
Resolve tenant ID class representation to Apache Pulsar tenant name (as
String). |
| TopicResolver |
Process input string to determine real topic name for Apache Pulsar.
|
| Class | Description |
|---|---|
| DefaultListener |
Default listener for incoming Pulsar messages.
|
| DefaultSchemaHandler |
Message type resolver for Pulsar schema.
|
| ListenerKotlinHelper |
Kotlin helper class that bridges Java calls from Pulsar Java library into suspend calls to Kotlin.
|
| PulsarArgumentHandler |
Helper processor class for arguments and headers on Pulsar consumers / processors.
|
| PulsarConsumerProcessor |
Processes beans containing methods annotated with @PulsarConsumer.
|
| TopicResolver.TopicResolved |
Simple container class for describing resolved topics.
|