Package org.springframework.pulsar.reactive.listener

Interface ReactivePulsarMessageListenerContainer<T>

Type Parameters:

T - message type.

All Superinterfaces:

DisposableBean, Lifecycle, MessageListenerContainer, Phased, SmartLifecycle

All Known Implementing Classes:

DefaultReactivePulsarMessageListenerContainer

public sealed interface ReactivePulsarMessageListenerContainer<T>
extends MessageListenerContainer
permits DefaultReactivePulsarMessageListenerContainer<T>

Internal abstraction used by the framework representing a reactive message listener container. Not meant to be implemented externally.

Author:

Christophe Bornet

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Method Summary

Modifier and Type	Method	Description
default ReactivePulsarContainerProperties<T>	getContainerProperties()
void	setConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer)
void	setupMessageHandler(ReactivePulsarMessageHandler messageListener)

Methods inherited from interface org.springframework.context.Lifecycle

isRunning, start, stop

Methods inherited from interface org.springframework.pulsar.listener.MessageListenerContainer

destroy, setAutoStartup

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, isAutoStartup, stop

Method Details

setupMessageHandler

void setupMessageHandler(ReactivePulsarMessageHandler messageListener)

getContainerProperties

default ReactivePulsarContainerProperties<T> getContainerProperties()

setConsumerCustomizer

void setConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer)