Class AmqpListenerEndpointRegistry
java.lang.Object
org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
- All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware
public class AmqpListenerEndpointRegistry
extends Object
implements org.springframework.context.ApplicationContextAware
An infrastructure bean to process
AmqpListenerEndpointRegistration instances.- Since:
- 4.1
-
Constructor Summary
ConstructorsConstructorDescriptionAmqpListenerEndpointRegistry(AmqpMessageListenerContainerFactory amqpMessageListenerContainerFactory) -
Method Summary
Modifier and TypeMethodDescriptionregisterListenerEndpoint(AmqpListenerEndpoint endpoint) RegisterAmqpMessageListenerContainerbean based on the providedAmqpListenerEndpoint.registerListenerEndpoint(AmqpMessageListenerContainerFactory containerFactory, AmqpListenerEndpoint endpoint) RegisterAmqpMessageListenerContainerbean based on the providedAmqpListenerEndpointandAmqpMessageListenerContainerFactory.registerListenerEndpoints(AmqpListenerEndpointRegistration registration) RegisterAmqpMessageListenerContainerbeans based on the providedAmqpListenerEndpointRegistration.voidsetApplicationContext(org.springframework.context.ApplicationContext applicationContext)
-
Constructor Details
-
AmqpListenerEndpointRegistry
public AmqpListenerEndpointRegistry() -
AmqpListenerEndpointRegistry
public AmqpListenerEndpointRegistry(AmqpMessageListenerContainerFactory amqpMessageListenerContainerFactory)
-
-
Method Details
-
setApplicationContext
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException - Specified by:
setApplicationContextin interfaceorg.springframework.context.ApplicationContextAware- Throws:
org.springframework.beans.BeansException
-
registerListenerEndpoints
public AmqpListenerEndpointRegistry registerListenerEndpoints(AmqpListenerEndpointRegistration registration) RegisterAmqpMessageListenerContainerbeans based on the providedAmqpListenerEndpointRegistration.- Parameters:
registration- the registration with endpoints to process.- Returns:
- this registry.
-
registerListenerEndpoint
RegisterAmqpMessageListenerContainerbean based on the providedAmqpListenerEndpoint. The defaultAmqpMessageListenerContainerFactoryis required in this case.- Parameters:
endpoint- the endpoint to process from.- Returns:
- this registry.
-
registerListenerEndpoint
public AmqpListenerEndpointRegistry registerListenerEndpoint(AmqpMessageListenerContainerFactory containerFactory, AmqpListenerEndpoint endpoint) RegisterAmqpMessageListenerContainerbean based on the providedAmqpListenerEndpointandAmqpMessageListenerContainerFactory.- Parameters:
containerFactory- the factory to create a message listener container from.endpoint- the endpoint to process from.- Returns:
- this registry.
-