Package org.flowable.eventregistry.spring.jms

Class JmsChannelModelProcessor

java.lang.Object

org.flowable.eventregistry.spring.jms.JmsChannelModelProcessor

All Implemented Interfaces:

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

public class JmsChannelModelProcessor
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 JmsListenerContainerFactory<?>	containerFactory
protected String	containerFactoryBeanName
protected boolean	contextRefreshed
protected StringValueResolver	embeddedValueResolver
protected JmsListenerEndpointRegistry	endpointRegistry
protected JmsOperations	jmsOperations
protected final org.slf4j.Logger	logger
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	canProcess(ChannelModel channelModel)
boolean	canProcessIfChannelModelAlreadyRegistered(ChannelModel channelModel)
protected JmsListenerEndpoint	createJmsListenerEndpoint(JmsInboundChannelModel jmsChannelModel, String tenantId, EventRegistry eventRegistry)
protected jakarta.jms.MessageListener	createMessageListener(EventRegistry eventRegistry, InboundChannelModel inboundChannelModel)
protected OutboundEventChannelAdapter	createOutboundEventChannelAdapter(JmsOutboundChannelModel channelModel)
JmsListenerContainerFactory<?>	getContainerFactory()
String	getContainerFactoryBeanName()
protected String	getEndpointId(ChannelModel channelModel, String tenantId)
JmsListenerEndpointRegistry	getEndpointRegistry()
JmsOperations	getJmsOperations()
void	onApplicationEvent(ContextRefreshedEvent event)
protected void	processOutboundDefinition(JmsOutboundChannelModel channelModel)
void	registerChannelModel(ChannelModel channelModel, String tenantId, EventRegistry eventRegistry, EventRepositoryService eventRepositoryService, boolean fallbackToDefaultTenant)
protected void	registerEndpoint(JmsListenerEndpoint endpoint, JmsListenerContainerFactory<?> factory)	Register a new JmsListenerEndpoint alongside the JmsListenerContainerFactory to use to create the underlying container.
protected String	resolve(String value)
protected JmsListenerContainerFactory<?>	resolveContainerFactory(JmsListenerEndpoint endpoint, JmsListenerContainerFactory<?> containerFactory)
void	setApplicationContext(ApplicationContext applicationContext)
void	setBeanFactory(BeanFactory beanFactory)
void	setContainerFactory(JmsListenerContainerFactory<?> containerFactory)
void	setContainerFactoryBeanName(String containerFactoryBeanName)
void	setEndpointRegistry(JmsListenerEndpointRegistry endpointRegistry)
void	setJmsOperations(JmsOperations jmsOperations)
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

jmsOperations

protected JmsOperations jmsOperations

endpointRegistry

protected JmsListenerEndpointRegistry endpointRegistry

containerFactoryBeanName

protected String containerFactoryBeanName

containerFactory

protected JmsListenerContainerFactory<?> containerFactory

beanFactory

protected BeanFactory beanFactory

applicationContext

protected ApplicationContext applicationContext

contextRefreshed

protected boolean contextRefreshed

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

embeddedValueResolver

protected StringValueResolver embeddedValueResolver

Constructor Details

JmsChannelModelProcessor

public JmsChannelModelProcessor(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

createJmsListenerEndpoint

protected JmsListenerEndpoint createJmsListenerEndpoint(JmsInboundChannelModel jmsChannelModel,
 String tenantId,
 EventRegistry eventRegistry)

createMessageListener

protected jakarta.jms.MessageListener createMessageListener(EventRegistry eventRegistry,
 InboundChannelModel inboundChannelModel)

processOutboundDefinition

protected void processOutboundDefinition(JmsOutboundChannelModel channelModel)

createOutboundEventChannelAdapter

protected OutboundEventChannelAdapter createOutboundEventChannelAdapter(JmsOutboundChannelModel channelModel)

unregisterChannelModel

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

Specified by:

unregisterChannelModel in interface ChannelModelProcessor

registerEndpoint

protected void registerEndpoint(JmsListenerEndpoint endpoint,
 JmsListenerContainerFactory<?> factory)

Register a new JmsListenerEndpoint alongside the JmsListenerContainerFactory 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 JmsListenerContainerFactory<?> resolveContainerFactory(JmsListenerEndpoint endpoint,
 JmsListenerContainerFactory<?> 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>

getJmsOperations

public JmsOperations getJmsOperations()

setJmsOperations

public void setJmsOperations(JmsOperations jmsOperations)

getEndpointRegistry

public JmsListenerEndpointRegistry getEndpointRegistry()

setEndpointRegistry

public void setEndpointRegistry(JmsListenerEndpointRegistry endpointRegistry)

getContainerFactoryBeanName

public String getContainerFactoryBeanName()

setContainerFactoryBeanName

public void setContainerFactoryBeanName(String containerFactoryBeanName)

getContainerFactory

public JmsListenerContainerFactory<?> getContainerFactory()

setContainerFactory

public void setContainerFactory(JmsListenerContainerFactory<?> containerFactory)