Package com.flowable.platform.engine.impl.eventregistry.mail

Class MailChannelModelProcessor

java.lang.Object

com.flowable.platform.engine.impl.eventregistry.mail.MailChannelModelProcessor

All Implemented Interfaces:

ChannelModelProcessor, Aware, BeanFactoryAware

public class MailChannelModelProcessor
extends Object
implements ChannelModelProcessor, BeanFactoryAware

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	MailChannelModelProcessor.BasicAuthenticator
static class	MailChannelModelProcessor.ChannelOverrideConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
protected BeanFactory	beanFactory
static final String	CHANNEL_ID_PREFIX
protected Map<String,MailChannelModelProcessor.ChannelOverrideConfiguration>	channelOverrideConfigurations
protected MailListenerContainerFactory	containerFactory
protected String	containerFactoryBeanName
protected StringValueResolver	embeddedValueResolver
protected BeanExpressionContext	expressionContext
protected org.springframework.integration.dsl.context.IntegrationFlowContext	integrationFlowContext
protected MessagePayloadExtractor	messagePayloadExtractor
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected BeanExpressionResolver	resolver
protected static final InboundEventProcessingPipeline	UNSUPPORTED_EVENT_PROCESSING_PIPELINE

Constructor Summary

Constructors

Constructor	Description
MailChannelModelProcessor(org.springframework.integration.dsl.context.IntegrationFlowContext integrationFlowContext, com.fasterxml.jackson.databind.ObjectMapper objectMapper, MessagePayloadExtractor messagePayloadExtractor)

Method Summary

Modifier and Type	Method	Description
boolean	canProcess(ChannelModel channelModel)
boolean	canProcessIfChannelModelAlreadyRegistered(ChannelModel channelModel)
protected MailListenerEndpoint	createListenerEndpoint(MailInboundChannelModel model, String tenantId)
protected MessageHandler	createMessageHandler(EventRegistry eventRegistry, MailInboundChannelModel channelModel, String tenantId)
Map<String,MailChannelModelProcessor.ChannelOverrideConfiguration>	getChannelOverrideConfigurations()
MailListenerContainerFactory	getContainerFactory()
String	getContainerFactoryBeanName()
protected String	getEndpointId(ChannelModel channelModel, String tenantId)
org.springframework.integration.dsl.context.IntegrationFlowContext	getIntegrationFlowContext()
MessagePayloadExtractor	getMessagePayloadExtractor()
com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper()
protected void	processInboundModel(MailInboundChannelModel channelModel, String tenantId, EventRegistry eventRegistry)
void	registerChannelModel(ChannelModel channelModel, String tenantId, EventRegistry eventRegistry, EventRepositoryService eventRepositoryService, boolean fallbackToDefaultTenant)
protected void	registerEndpoint(MailListenerEndpoint endpoint, MessageHandler messageHandler)
protected String	resolve(String value)
protected jakarta.mail.Authenticator	resolveAuthenticator(MailInboundChannelModel model)
protected MailListenerContainerFactory	resolveContainerFactory(MailListenerEndpoint endpoint)
protected Duration	resolveDurationExpression(String value, String attribute)
protected InboundEventTenantDetector<jakarta.mail.internet.MimeMessage>	resolveEventTenantDetector(MailInboundChannelModel channelModel, String defaultTenantId)
protected Object	resolveExpression(String value)
protected jakarta.mail.Authenticator	resolveExpressionAsAuthenticator(String delegatingAuthenticator, String modelKey)
protected Boolean	resolveExpressionAsBoolean(String value, String attribute)
protected Long	resolveExpressionAsLong(String value, String attribute)
protected String	resolveExpressionAsString(String value, String attribute)
protected <T> T	resolveFlowableExpression(String expression, Class<T> type, String modelKey)
protected Properties	resolveProperties(List<MailInboundChannelModel.CustomProperty> mailProperties)
protected String	resolveUrl(MailInboundChannelModel channelModel)
void	setBeanFactory(BeanFactory beanFactory)
void	setChannelOverrideConfigurations(Map<String,MailChannelModelProcessor.ChannelOverrideConfiguration> channelOverrideConfigurations)
void	setContainerFactory(MailListenerContainerFactory containerFactory)
void	setContainerFactoryBeanName(String containerFactoryBeanName)
void	setIntegrationFlowContext(org.springframework.integration.dsl.context.IntegrationFlowContext integrationFlowContext)
void	setMessagePayloadExtractor(MessagePayloadExtractor messagePayloadExtractor)
void	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
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

Field Details

CHANNEL_ID_PREFIX

public static final String CHANNEL_ID_PREFIX

See Also:

• Constant Field Values

UNSUPPORTED_EVENT_PROCESSING_PIPELINE

protected static final InboundEventProcessingPipeline UNSUPPORTED_EVENT_PROCESSING_PIPELINE

integrationFlowContext

protected org.springframework.integration.dsl.context.IntegrationFlowContext integrationFlowContext

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

messagePayloadExtractor

protected MessagePayloadExtractor messagePayloadExtractor

containerFactoryBeanName

protected String containerFactoryBeanName

containerFactory

protected MailListenerContainerFactory containerFactory

channelOverrideConfigurations

protected Map<String,MailChannelModelProcessor.ChannelOverrideConfiguration> channelOverrideConfigurations

beanFactory

protected BeanFactory beanFactory

resolver

protected BeanExpressionResolver resolver

embeddedValueResolver

protected StringValueResolver embeddedValueResolver

expressionContext

protected BeanExpressionContext expressionContext

Constructor Details

MailChannelModelProcessor

public MailChannelModelProcessor(org.springframework.integration.dsl.context.IntegrationFlowContext integrationFlowContext,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 MessagePayloadExtractor messagePayloadExtractor)

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

processInboundModel

protected void processInboundModel(MailInboundChannelModel channelModel,
 String tenantId,
 EventRegistry eventRegistry)

registerEndpoint

protected void registerEndpoint(MailListenerEndpoint endpoint,
 MessageHandler messageHandler)

createListenerEndpoint

protected MailListenerEndpoint createListenerEndpoint(MailInboundChannelModel model,
 String tenantId)

createMessageHandler

protected MessageHandler createMessageHandler(EventRegistry eventRegistry,
 MailInboundChannelModel channelModel,
 String tenantId)

resolveEventTenantDetector

protected InboundEventTenantDetector<jakarta.mail.internet.MimeMessage> resolveEventTenantDetector(MailInboundChannelModel channelModel,
 String defaultTenantId)

resolveContainerFactory

protected MailListenerContainerFactory resolveContainerFactory(MailListenerEndpoint endpoint)

getEndpointId

protected String getEndpointId(ChannelModel channelModel,
 String tenantId)

resolveAuthenticator

protected jakarta.mail.Authenticator resolveAuthenticator(MailInboundChannelModel model)

resolveExpressionAsAuthenticator

protected jakarta.mail.Authenticator resolveExpressionAsAuthenticator(String delegatingAuthenticator,
 String modelKey)

resolveDurationExpression

protected Duration resolveDurationExpression(String value,
 String attribute)

resolveExpressionAsBoolean

protected Boolean resolveExpressionAsBoolean(String value,
 String attribute)

resolveExpressionAsLong

protected Long resolveExpressionAsLong(String value,
 String attribute)

resolveUrl

protected String resolveUrl(MailInboundChannelModel channelModel)

resolveExpressionAsString

protected String resolveExpressionAsString(String value,
 String attribute)

resolveExpression

protected Object resolveExpression(String value)

resolve

protected String resolve(String value)

resolveFlowableExpression

protected <T> T resolveFlowableExpression(String expression,
 Class<T> type,
 String modelKey)

resolveProperties

protected Properties resolveProperties(List<MailInboundChannelModel.CustomProperty> mailProperties)

unregisterChannelModel

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

Specified by:

unregisterChannelModel in interface ChannelModelProcessor

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

getIntegrationFlowContext

public org.springframework.integration.dsl.context.IntegrationFlowContext getIntegrationFlowContext()

setIntegrationFlowContext

public void setIntegrationFlowContext(org.springframework.integration.dsl.context.IntegrationFlowContext integrationFlowContext)

getObjectMapper

public com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()

setObjectMapper

public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

getMessagePayloadExtractor

public MessagePayloadExtractor getMessagePayloadExtractor()

setMessagePayloadExtractor

public void setMessagePayloadExtractor(MessagePayloadExtractor messagePayloadExtractor)

getContainerFactoryBeanName

public String getContainerFactoryBeanName()

setContainerFactoryBeanName

public void setContainerFactoryBeanName(String containerFactoryBeanName)

getContainerFactory

public MailListenerContainerFactory getContainerFactory()

setContainerFactory

public void setContainerFactory(MailListenerContainerFactory containerFactory)

getChannelOverrideConfigurations

public Map<String,MailChannelModelProcessor.ChannelOverrideConfiguration> getChannelOverrideConfigurations()

setChannelOverrideConfigurations

public void setChannelOverrideConfigurations(Map<String,MailChannelModelProcessor.ChannelOverrideConfiguration> channelOverrideConfigurations)