| Interface | Description |
|---|---|
| MessageListenerResolver |
Provides flexibility to implement
MessageListener as beans
while still being able to override default listener resolver for Pulsar Consumers. |
| Class | Description |
|---|---|
| DefaultListener |
Default listener for incoming Pulsar messages.
|
| ListenerKotlinHelper |
Kotlin helper class that bridges Java calls from Pulsar Java library into suspend calls to Kotlin.
|
| PulsarConsumerProcessor |
Processes beans containing methods annotated with @PulsarConsumer.
|
| SchemaResolver |
Message type resolver for Pulsar schema.
|