Package org.flowable.eventregistry.spring.rabbit

Class RabbitChannelDefinitionProcessor

java.lang.Object

org.flowable.eventregistry.spring.rabbit.RabbitChannelDefinitionProcessor

All Implemented Interfaces:

EventListener, ChannelModelProcessor, Aware, BeanFactoryAware, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>

public class RabbitChannelDefinitionProcessor
extends Object
implements BeanFactoryAware, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, ChannelModelProcessor

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected ApplicationContext	applicationContext
protected BeanFactory	beanFactory
static final String	CHANNEL_ID_PREFIX
protected RabbitListenerContainerFactory<?>	containerFactory
protected String	containerFactoryBeanName
protected boolean	contextRefreshed
protected StringValueResolver	embeddedValueResolver
protected RabbitListenerEndpointRegistry	endpointRegistry
protected BeanExpressionContext	expressionContext
protected final org.slf4j.Logger	logger
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected RabbitOperations	rabbitOperations
protected BeanExpressionResolver	resolver

Constructor Summary

Constructors

Constructor	Description
RabbitChannelDefinitionProcessor(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
boolean	canProcess(ChannelModel channelModel)
boolean	canProcessIfChannelModelAlreadyRegistered(ChannelModel channelModel)
protected MessageListener	createMessageListener(EventRegistry eventRegistry, InboundChannelModel inboundChannelModel)
protected RabbitListenerEndpoint	createRabbitListenerEndpoint(RabbitInboundChannelModel channelModel, String tenantId, EventRegistry eventRegistry)
RabbitListenerContainerFactory<?>	getContainerFactory()
String	getContainerFactoryBeanName()
protected String	getEndpointId(ChannelModel channelModel, String tenantId)
RabbitListenerEndpointRegistry	getEndpointRegistry()
RabbitOperations	getRabbitOperations()
void	onApplicationEvent(ContextRefreshedEvent event)
protected void	processOutboundDefinition(RabbitOutboundChannelModel channelDefinition)
void	registerChannelModel(ChannelModel channelModel, String tenantId, EventRegistry eventRegistry, EventRepositoryService eventRepositoryService, boolean fallbackToDefaultTenant)
protected void	registerEndpoint(RabbitListenerEndpoint endpoint, RabbitListenerContainerFactory<?> factory)	Register a new RabbitListenerEndpoint alongside the RabbitListenerContainerFactory to use to create the underlying container.
protected String	resolve(String value)
protected AcknowledgeMode	resolveAckMode(RabbitInboundChannelModel channelDefinition)
protected RabbitAdmin	resolveAdmin(RabbitInboundChannelModel channelDefinition)
protected RabbitListenerContainerFactory<?>	resolveContainerFactory(RabbitListenerEndpoint endpoint, RabbitListenerContainerFactory<?> containerFactory)
protected 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(ApplicationContext applicationContext)
void	setBeanFactory(BeanFactory beanFactory)
void	setContainerFactory(RabbitListenerContainerFactory<?> containerFactory)
void	setContainerFactoryBeanName(String containerFactoryBeanName)
void	setEndpointRegistry(RabbitListenerEndpointRegistry endpointRegistry)
void	setRabbitOperations(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

supportsAsyncExecution

Field Details

CHANNEL_ID_PREFIX

public static final String CHANNEL_ID_PREFIX

See Also:

• Constant Field Values

logger

protected final org.slf4j.Logger logger

endpointRegistry

protected RabbitListenerEndpointRegistry endpointRegistry

containerFactoryBeanName

protected String containerFactoryBeanName

rabbitOperations

protected RabbitOperations rabbitOperations

containerFactory

protected RabbitListenerContainerFactory<?> containerFactory

beanFactory

protected BeanFactory beanFactory

applicationContext

protected ApplicationContext applicationContext

contextRefreshed

protected boolean contextRefreshed

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

resolver

protected BeanExpressionResolver resolver

embeddedValueResolver

protected StringValueResolver embeddedValueResolver

expressionContext

protected BeanExpressionContext expressionContext

Constructor Details

RabbitChannelDefinitionProcessor

public RabbitChannelDefinitionProcessor(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

canProcess

public boolean canProcess(ChannelModel channelModel)

Specified by:

canProcess in interface ChannelModelProcessor

canProcessIfChannelModelAlreadyRegistered

public boolean canProcessIfChannelModelAlreadyRegistered(ChannelModel channelModel)

Specified by:

canProcessIfChannelModelAlreadyRegistered 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 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 RabbitAdmin resolveAdmin(RabbitInboundChannelModel channelDefinition)

resolveAckMode

protected AcknowledgeMode resolveAckMode(RabbitInboundChannelModel channelDefinition)

resolveExecutor

protected TaskExecutor resolveExecutor(RabbitInboundChannelModel channelDefinition)

resolveExpression

protected Object resolveExpression(String value)

createMessageListener

protected 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(RabbitListenerEndpoint endpoint,
 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 RabbitListenerContainerFactory<?> resolveContainerFactory(RabbitListenerEndpoint endpoint,
 RabbitListenerContainerFactory<?> containerFactory)

getEndpointId

protected String getEndpointId(ChannelModel channelModel,
 String tenantId)

resolve

protected String resolve(String value)

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

onApplicationEvent

public void onApplicationEvent(ContextRefreshedEvent event)

Specified by:

onApplicationEvent in interface ApplicationListener<ContextRefreshedEvent>

getRabbitOperations

public RabbitOperations getRabbitOperations()

setRabbitOperations

public void setRabbitOperations(RabbitOperations rabbitOperations)

getEndpointRegistry

public RabbitListenerEndpointRegistry getEndpointRegistry()

setEndpointRegistry

public void setEndpointRegistry(RabbitListenerEndpointRegistry endpointRegistry)

getContainerFactoryBeanName

public String getContainerFactoryBeanName()

setContainerFactoryBeanName

public void setContainerFactoryBeanName(String containerFactoryBeanName)

getContainerFactory

public RabbitListenerContainerFactory<?> getContainerFactory()

setContainerFactory

public void setContainerFactory(RabbitListenerContainerFactory<?> containerFactory)