Package org.springframework.kafka.config

Class KafkaListenerEndpointRegistry

java.lang.Object

org.springframework.kafka.config.KafkaListenerEndpointRegistry

All Implemented Interfaces:

EventListener, Aware, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, Lifecycle, Phased, SmartLifecycle, ListenerContainerRegistry

public class KafkaListenerEndpointRegistry
extends Object
implements ListenerContainerRegistry, DisposableBean, SmartLifecycle, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>

Creates the necessary MessageListenerContainer instances for the registered endpoints. Also manages the lifecycle of the listener containers, in particular within the lifecycle of the application context.

Contrary to MessageListenerContainers created manually, listener containers managed by registry are not beans in the application context and are not candidates for autowiring. Use getListenerContainers() if you need to access this registry's listener containers for management purposes. If you need to access to a specific message listener container, use getListenerContainer(String) with the id of the endpoint.

Author:

Stephane Nicoll, Juergen Hoeller, Artem Bilan, Gary Russell, Asi Bross, Wang Zhiyang, Joo Hyuk Kim

See Also:

• KafkaListenerEndpoint
• MessageListenerContainer
• KafkaListenerContainerFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected final LogAccessor	logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
KafkaListenerEndpointRegistry()

Method Summary

Modifier and Type	Method	Description
protected MessageListenerContainer	createListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory)	Create and start a new MessageListenerContainer using the specified factory.
void	destroy()
Collection<MessageListenerContainer>	getAllListenerContainers()	Return all MessageListenerContainer instances including those managed by this registry and those declared as beans in the application context.
MessageListenerContainer	getListenerContainer(String id)	Return the MessageListenerContainer with the specified id or null if no such container exists.
Set<String>	getListenerContainerIds()	Return the ids of the managed MessageListenerContainer instance(s).
Collection<MessageListenerContainer>	getListenerContainers()	Return the managed MessageListenerContainer instance(s).
Collection<MessageListenerContainer>	getListenerContainersMatching(BiPredicate<String,MessageListenerContainer> idAndContainerMatcher)	Return all MessageListenerContainer instances that satisfy the given bi-predicate.
Collection<MessageListenerContainer>	getListenerContainersMatching(Predicate<String> idMatcher)	Return all MessageListenerContainer instances with id matching the predicate or empty Collection if no such container exists.
int	getPhase()
MessageListenerContainer	getUnregisteredListenerContainer(String id)	Return the MessageListenerContainer with the specified id or null if no such container exists.
boolean	isRunning()
void	onApplicationEvent(ContextRefreshedEvent event)
void	registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory)	Create a message listener container for the given KafkaListenerEndpoint.
void	registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory, boolean startImmediately)	Create a message listener container for the given KafkaListenerEndpoint.
void	setAlwaysStartAfterRefresh(boolean alwaysStartAfterRefresh)	By default, containers registered for endpoints after the context is refreshed are immediately started, regardless of their autoStartup property, to comply with the SmartLifecycle contract, where autoStartup is only considered during context initialization.
void	setApplicationContext(ApplicationContext applicationContext)
void	start()
void	stop()
void	stop(Runnable callback)
MessageListenerContainer	unregisterListenerContainer(String id)	Unregister the listener container with the provided id.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.context.ApplicationListener

supportsAsyncExecution

Methods inherited from interface org.springframework.context.SmartLifecycle

isAutoStartup

Field Details

logger

protected final LogAccessor logger

Constructor Details

KafkaListenerEndpointRegistry

public KafkaListenerEndpointRegistry()

Method Details

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

getListenerContainer

@Nullable
public MessageListenerContainer getListenerContainer(String id)

Return the MessageListenerContainer with the specified id or null if no such container exists.

Specified by:

getListenerContainer in interface ListenerContainerRegistry

Parameters:

id - the id of the container

Returns:

the container or null if no container with that id exists

See Also:

• KafkaListenerEndpoint.getId()
• getListenerContainerIds()

getListenerContainersMatching

public Collection<MessageListenerContainer> getListenerContainersMatching(Predicate<String> idMatcher)

Return all MessageListenerContainer instances with id matching the predicate or empty Collection if no such container exists.

Specified by:

getListenerContainersMatching in interface ListenerContainerRegistry

Parameters:

idMatcher - the predicate to match container id with

Returns:

the containers or empty Collection if no container with that id exists

Since:

3.2

See Also:

• getListenerContainerIds()
• getListenerContainer(String)

getListenerContainersMatching

public Collection<MessageListenerContainer> getListenerContainersMatching(BiPredicate<String,MessageListenerContainer> idAndContainerMatcher)

Return all MessageListenerContainer instances that satisfy the given bi-predicate. The BiPredicate<String, MessageListenerContainer> takes the container id and the container itself as arguments. This allows for more sophisticated filtering, including properties or state of the container itself.

Specified by:

getListenerContainersMatching in interface ListenerContainerRegistry

Parameters:

idAndContainerMatcher - the bi-predicate to match the container id and the container

Returns:

the containers that match the bi-predicate criteria or an empty Collection if no matching containers exist

Since:

3.2

See Also:

• getListenerContainerIds()
• getListenerContainersMatching(Predicate)

getUnregisteredListenerContainer

@Nullable
public MessageListenerContainer getUnregisteredListenerContainer(String id)

Description copied from interface: ListenerContainerRegistry

Return the MessageListenerContainer with the specified id or null if no such container exists. Returns containers that are not registered with the registry, but exist in the application context.

Specified by:

getUnregisteredListenerContainer in interface ListenerContainerRegistry

Parameters:

id - the id of the container

Returns:

the container or null if no container with that id exists

See Also:

• ListenerContainerRegistry.getListenerContainerIds()

setAlwaysStartAfterRefresh

public void setAlwaysStartAfterRefresh(boolean alwaysStartAfterRefresh)

By default, containers registered for endpoints after the context is refreshed are immediately started, regardless of their autoStartup property, to comply with the SmartLifecycle contract, where autoStartup is only considered during context initialization. Set to false to apply the autoStartup property, even for late endpoint binding. If this is called after the context is refreshed, it will apply to any endpoints registered after that call.

Parameters:

alwaysStartAfterRefresh - false to apply the property.

Since:

2.8.7

getListenerContainerIds

public Set<String> getListenerContainerIds()

Return the ids of the managed MessageListenerContainer instance(s).

Specified by:

getListenerContainerIds in interface ListenerContainerRegistry

Returns:

the ids.

See Also:

• getListenerContainer(String)

getListenerContainers

public Collection<MessageListenerContainer> getListenerContainers()

Return the managed MessageListenerContainer instance(s).

Specified by:

getListenerContainers in interface ListenerContainerRegistry

Returns:

the managed MessageListenerContainer instance(s).

See Also:

• getAllListenerContainers()

getAllListenerContainers

public Collection<MessageListenerContainer> getAllListenerContainers()

Return all MessageListenerContainer instances including those managed by this registry and those declared as beans in the application context. Prototype-scoped containers will be included. Lazy beans that have not yet been created will not be initialized by a call to this method.

Specified by:

getAllListenerContainers in interface ListenerContainerRegistry

Returns:

the MessageListenerContainer instance(s).

Since:

2.2.5

See Also:

• getListenerContainers()

registerListenerContainer

public void registerListenerContainer(KafkaListenerEndpoint endpoint,
 KafkaListenerContainerFactory<?> factory)

Create a message listener container for the given KafkaListenerEndpoint.

This create the necessary infrastructure to honor that endpoint with regards to its configuration.

Parameters:

endpoint - the endpoint to add

factory - the listener factory to use

See Also:

• registerListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory, boolean)

registerListenerContainer

public void registerListenerContainer(KafkaListenerEndpoint endpoint,
 KafkaListenerContainerFactory<?> factory,
 boolean startImmediately)

Create a message listener container for the given KafkaListenerEndpoint.

This create the necessary infrastructure to honor that endpoint with regards to its configuration.

The startImmediately flag determines if the container should be started immediately.

Parameters:

endpoint - the endpoint to add.

factory - the KafkaListenerContainerFactory to use.

startImmediately - start the container immediately if necessary

See Also:

• getListenerContainers()
• getListenerContainer(String)

unregisterListenerContainer

@Nullable
public MessageListenerContainer unregisterListenerContainer(String id)

Unregister the listener container with the provided id.

IMPORTANT: this method simply removes the container from the registry. It does NOT call any Lifecycle or DisposableBean methods; you need to call them before or after calling this method to shut down the container.

Parameters:

id - the id.

Returns:

the container, if it was registered; null otherwise.

Since:

2.8.9

createListenerContainer

protected MessageListenerContainer createListenerContainer(KafkaListenerEndpoint endpoint,
 KafkaListenerContainerFactory<?> factory)

Create and start a new MessageListenerContainer using the specified factory.

Parameters:

endpoint - the endpoint to create a MessageListenerContainer.

factory - the KafkaListenerContainerFactory to use.

Returns:

the MessageListenerContainer.

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean

getPhase

public int getPhase()

Specified by:

getPhase in interface Phased

Specified by:

getPhase in interface SmartLifecycle

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface SmartLifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

onApplicationEvent

public void onApplicationEvent(ContextRefreshedEvent event)

Specified by:

onApplicationEvent in interface ApplicationListener<ContextRefreshedEvent>