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
| 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 and Description |
|---|
RabbitChannelDefinitionProcessor() |
| 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) |
public static final String CHANNEL_ID_PREFIX
protected final org.slf4j.Logger logger
protected org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry endpointRegistry
protected String containerFactoryBeanName
protected org.springframework.amqp.rabbit.core.RabbitOperations rabbitOperations
protected org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> containerFactory
protected org.springframework.beans.factory.BeanFactory beanFactory
protected org.springframework.context.ApplicationContext applicationContext
protected boolean contextRefreshed
protected org.springframework.beans.factory.config.BeanExpressionResolver resolver
protected org.springframework.util.StringValueResolver embeddedValueResolver
protected org.springframework.beans.factory.config.BeanExpressionContext expressionContext
public boolean canProcess(ChannelModel channelModel)
canProcess in interface ChannelModelProcessorpublic void registerChannelModel(ChannelModel channelModel, String tenantId, EventRegistry eventRegistry, EventRepositoryService eventRepositoryService, boolean fallbackToDefaultTenant)
registerChannelModel in interface ChannelModelProcessorprotected org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint createRabbitListenerEndpoint(RabbitInboundChannelModel channelModel, String tenantId, EventRegistry eventRegistry)
protected void processOutboundDefinition(RabbitOutboundChannelModel channelDefinition)
protected String resolveExpressionAsStringOrInteger(String value, String attribute)
protected String[] resolveQueues(RabbitInboundChannelModel channelDefinition)
protected void resolveQueues(Object resolvedValue, List<String> result, RabbitInboundChannelModel channelDefinition)
protected Integer resolvePriority(RabbitInboundChannelModel channelDefinition)
protected org.springframework.amqp.rabbit.core.RabbitAdmin resolveAdmin(RabbitInboundChannelModel channelDefinition)
protected org.springframework.amqp.core.AcknowledgeMode resolveAckMode(RabbitInboundChannelModel channelDefinition)
protected org.springframework.core.task.TaskExecutor resolveExecutor(RabbitInboundChannelModel channelDefinition)
protected org.springframework.amqp.core.MessageListener createMessageListener(EventRegistry eventRegistry, InboundChannelModel inboundChannelModel)
public void unregisterChannelModel(ChannelModel channelModel, String tenantId, EventRepositoryService eventRepositoryService)
unregisterChannelModel in interface ChannelModelProcessorprotected void registerEndpoint(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint,
org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> factory)
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.
protected org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> resolveContainerFactory(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint,
org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> containerFactory)
protected String getEndpointId(ChannelModel channelModel, String tenantId)
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
throws org.springframework.beans.BeansException
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAwareorg.springframework.beans.BeansExceptionpublic void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
throws org.springframework.beans.BeansException
setApplicationContext in interface org.springframework.context.ApplicationContextAwareorg.springframework.beans.BeansExceptionpublic void onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)
onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>public org.springframework.amqp.rabbit.core.RabbitOperations getRabbitOperations()
public void setRabbitOperations(org.springframework.amqp.rabbit.core.RabbitOperations rabbitOperations)
public org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry getEndpointRegistry()
public void setEndpointRegistry(org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry endpointRegistry)
public String getContainerFactoryBeanName()
public void setContainerFactoryBeanName(String containerFactoryBeanName)
public org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> getContainerFactory()
public void setContainerFactory(org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<?> containerFactory)
Copyright © 2023 Flowable. All rights reserved.