org.flowable.eventregistry.spring.rabbit

Class RabbitChannelDefinitionProcessor

java.lang.Object

org.flowable.eventregistry.spring.rabbit.RabbitChannelDefinitionProcessor

All Implemented Interfaces:

EventListener, ChannelModelProcessor, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>

public class RabbitChannelDefinitionProcessor
extends Object
implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>, ChannelModelProcessor

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.context.ApplicationContext	applicationContext
protected org.springframework.beans.factory.BeanFactory	beanFactory
static String	CHANNEL_ID_PREFIX
protected org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?>	containerFactory
protected String	containerFactoryBeanName
protected boolean	contextRefreshed
protected org.springframework.util.StringValueResolver	embeddedValueResolver
protected org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry	endpointRegistry
protected org.springframework.beans.factory.config.BeanExpressionContext	expressionContext
protected org.slf4j.Logger	logger
protected org.springframework.amqp.rabbit.core.RabbitOperations	rabbitOperations
protected org.springframework.beans.factory.config.BeanExpressionResolver	resolver

Constructor Summary

Constructors

Constructor and Description
RabbitChannelDefinitionProcessor()

Method Summary

Modifier and Type	Method and Description
boolean	canProcess(ChannelModel channelModel)
protected org.springframework.amqp.core.MessageListener	createMessageListener(EventRegistry eventRegistry, InboundChannelModel inboundChannelModel)
protected org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint	createRabbitListenerEndpoint(RabbitInboundChannelModel channelModel, String tenantId, EventRegistry eventRegistry)
org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?>	getContainerFactory()
String	getContainerFactoryBeanName()
protected String	getEndpointId(ChannelModel channelModel, String tenantId)
org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry	getEndpointRegistry()
org.springframework.amqp.rabbit.core.RabbitOperations	getRabbitOperations()
void	onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)
protected void	processOutboundDefinition(RabbitOutboundChannelModel channelDefinition)
void	registerChannelModel(ChannelModel channelModel, String tenantId, EventRegistry eventRegistry, EventRepositoryService eventRepositoryService, boolean fallbackToDefaultTenant)
protected void	registerEndpoint(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint, org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> factory) Register a new RabbitListenerEndpoint alongside the RabbitListenerContainerFactory to use to create the underlying container.
protected String	resolve(String value)
protected org.springframework.amqp.core.AcknowledgeMode	resolveAckMode(RabbitInboundChannelModel channelDefinition)
protected org.springframework.amqp.rabbit.core.RabbitAdmin	resolveAdmin(RabbitInboundChannelModel channelDefinition)
protected org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?>	resolveContainerFactory(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint, org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> containerFactory)
protected org.springframework.core.task.TaskExecutor	resolveExecutor(RabbitInboundChannelModel channelDefinition)
protected Object	resolveExpression(String value)
protected String	resolveExpressionAsStringOrInteger(String value, String attribute)
protected Integer	resolvePriority(RabbitInboundChannelModel channelDefinition)
protected void	resolveQueues(Object resolvedValue, List<String> result, RabbitInboundChannelModel channelDefinition)
protected String[]	resolveQueues(RabbitInboundChannelModel channelDefinition)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	setContainerFactory(org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> containerFactory)
void	setContainerFactoryBeanName(String containerFactoryBeanName)
void	setEndpointRegistry(org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry endpointRegistry)
void	setRabbitOperations(org.springframework.amqp.rabbit.core.RabbitOperations rabbitOperations)
void	unregisterChannelModel(ChannelModel channelModel, String tenantId, EventRepositoryService eventRepositoryService)

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

forPayload

Field Detail

CHANNEL_ID_PREFIX

public static final String CHANNEL_ID_PREFIX

See Also:

Constant Field Values

logger

protected final org.slf4j.Logger logger

endpointRegistry

protected org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry endpointRegistry

containerFactoryBeanName

protected String containerFactoryBeanName

rabbitOperations

protected org.springframework.amqp.rabbit.core.RabbitOperations rabbitOperations

containerFactory

protected org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> containerFactory

beanFactory

protected org.springframework.beans.factory.BeanFactory beanFactory

applicationContext

protected org.springframework.context.ApplicationContext applicationContext

contextRefreshed

protected boolean contextRefreshed

resolver

protected org.springframework.beans.factory.config.BeanExpressionResolver resolver

embeddedValueResolver

protected org.springframework.util.StringValueResolver embeddedValueResolver

expressionContext

protected org.springframework.beans.factory.config.BeanExpressionContext expressionContext

Constructor Detail

RabbitChannelDefinitionProcessor

public RabbitChannelDefinitionProcessor()

Method Detail

canProcess

public boolean canProcess(ChannelModel channelModel)

Specified by:

canProcess in interface ChannelModelProcessor

registerChannelModel

public void registerChannelModel(ChannelModel channelModel,
                                 String tenantId,
                                 EventRegistry eventRegistry,
                                 EventRepositoryService eventRepositoryService,
                                 boolean fallbackToDefaultTenant)

Specified by:

registerChannelModel in interface ChannelModelProcessor

createRabbitListenerEndpoint

protected org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint createRabbitListenerEndpoint(RabbitInboundChannelModel channelModel,
                                                                                                       String tenantId,
                                                                                                       EventRegistry eventRegistry)

processOutboundDefinition

protected void processOutboundDefinition(RabbitOutboundChannelModel channelDefinition)

resolveExpressionAsStringOrInteger

protected String resolveExpressionAsStringOrInteger(String value,
                                                    String attribute)

resolveQueues

protected String[] resolveQueues(RabbitInboundChannelModel channelDefinition)

resolveQueues

protected void resolveQueues(Object resolvedValue,
                             List<String> result,
                             RabbitInboundChannelModel channelDefinition)

resolvePriority

protected Integer resolvePriority(RabbitInboundChannelModel channelDefinition)

resolveAdmin

protected org.springframework.amqp.rabbit.core.RabbitAdmin resolveAdmin(RabbitInboundChannelModel channelDefinition)

resolveAckMode

protected org.springframework.amqp.core.AcknowledgeMode resolveAckMode(RabbitInboundChannelModel channelDefinition)

resolveExecutor

protected org.springframework.core.task.TaskExecutor resolveExecutor(RabbitInboundChannelModel channelDefinition)

resolveExpression

protected Object resolveExpression(String value)

createMessageListener

protected org.springframework.amqp.core.MessageListener createMessageListener(EventRegistry eventRegistry,
                                                                              InboundChannelModel inboundChannelModel)

unregisterChannelModel

public void unregisterChannelModel(ChannelModel channelModel,
                                   String tenantId,
                                   EventRepositoryService eventRepositoryService)

Specified by:

unregisterChannelModel in interface ChannelModelProcessor

registerEndpoint

protected void registerEndpoint(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint,
                                org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> factory)

Register a new RabbitListenerEndpoint alongside the RabbitListenerContainerFactory to use to create the underlying container.

The factory may be null if the default factory has to be used for that endpoint.

resolveContainerFactory

protected org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> resolveContainerFactory(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint,
                                                                                                             org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> containerFactory)

getEndpointId

protected String getEndpointId(ChannelModel channelModel,
                               String tenantId)

resolve

protected String resolve(String value)

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

onApplicationEvent

public void onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>

getRabbitOperations

public org.springframework.amqp.rabbit.core.RabbitOperations getRabbitOperations()

setRabbitOperations

public void setRabbitOperations(org.springframework.amqp.rabbit.core.RabbitOperations rabbitOperations)

getEndpointRegistry

public org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry getEndpointRegistry()

setEndpointRegistry

public void setEndpointRegistry(org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry endpointRegistry)

getContainerFactoryBeanName

public String getContainerFactoryBeanName()

setContainerFactoryBeanName

public void setContainerFactoryBeanName(String containerFactoryBeanName)

getContainerFactory

public org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> getContainerFactory()

setContainerFactory

public void setContainerFactory(org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> containerFactory)