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

Class MailChannelModelProcessor

java.lang.Object

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

All Implemented Interfaces:

org.flowable.eventregistry.api.ChannelModelProcessor, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware

public class MailChannelModelProcessor
extends java.lang.Object
implements org.flowable.eventregistry.api.ChannelModelProcessor, org.springframework.beans.factory.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 org.springframework.beans.factory.BeanFactory	beanFactory
static java.lang.String	CHANNEL_ID_PREFIX
protected java.util.Map<java.lang.String,MailChannelModelProcessor.ChannelOverrideConfiguration>	channelOverrideConfigurations
protected MailListenerContainerFactory	containerFactory
protected java.lang.String	containerFactoryBeanName
protected org.springframework.util.StringValueResolver	embeddedValueResolver
protected org.springframework.beans.factory.config.BeanExpressionContext	expressionContext
protected org.springframework.integration.dsl.context.IntegrationFlowContext	integrationFlowContext
protected MessagePayloadExtractor	messagePayloadExtractor
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected org.springframework.beans.factory.config.BeanExpressionResolver	resolver
protected static org.flowable.eventregistry.api.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(org.flowable.eventregistry.model.ChannelModel channelModel)
protected MailListenerEndpoint	createListenerEndpoint(MailInboundChannelModel model, java.lang.String tenantId)
protected org.springframework.messaging.MessageHandler	createMessageHandler(org.flowable.eventregistry.api.EventRegistry eventRegistry, MailInboundChannelModel channelModel, java.lang.String tenantId)
java.util.Map<java.lang.String,MailChannelModelProcessor.ChannelOverrideConfiguration>	getChannelOverrideConfigurations()
MailListenerContainerFactory	getContainerFactory()
java.lang.String	getContainerFactoryBeanName()
protected java.lang.String	getEndpointId(org.flowable.eventregistry.model.ChannelModel channelModel, java.lang.String tenantId)
org.springframework.integration.dsl.context.IntegrationFlowContext	getIntegrationFlowContext()
MessagePayloadExtractor	getMessagePayloadExtractor()
com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper()
protected void	processInboundModel(MailInboundChannelModel channelModel, java.lang.String tenantId, org.flowable.eventregistry.api.EventRegistry eventRegistry)
void	registerChannelModel(org.flowable.eventregistry.model.ChannelModel channelModel, java.lang.String tenantId, org.flowable.eventregistry.api.EventRegistry eventRegistry, org.flowable.eventregistry.api.EventRepositoryService eventRepositoryService, boolean fallbackToDefaultTenant)
protected void	registerEndpoint(MailListenerEndpoint endpoint, org.springframework.messaging.MessageHandler messageHandler)
protected java.lang.String	resolve(java.lang.String value)
protected javax.mail.Authenticator	resolveAuthenticator(MailInboundChannelModel model)
protected MailListenerContainerFactory	resolveContainerFactory(MailListenerEndpoint endpoint)
protected java.time.Duration	resolveDurationExpression(java.lang.String value, java.lang.String attribute)
protected java.lang.Object	resolveExpression(java.lang.String value)
protected java.lang.Boolean	resolveExpressionAsBoolean(java.lang.String value, java.lang.String attribute)
protected java.lang.Long	resolveExpressionAsLong(java.lang.String value, java.lang.String attribute)
protected java.lang.String	resolveExpressionAsString(java.lang.String value, java.lang.String attribute)
protected java.util.Properties	resolveProperties(java.util.List<MailInboundChannelModel.CustomProperty> mailProperties)
protected java.lang.String	resolveUrl(MailInboundChannelModel channelModel)
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	setChannelOverrideConfigurations(java.util.Map<java.lang.String,MailChannelModelProcessor.ChannelOverrideConfiguration> channelOverrideConfigurations)
void	setContainerFactory(MailListenerContainerFactory containerFactory)
void	setContainerFactoryBeanName(java.lang.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(org.flowable.eventregistry.model.ChannelModel channelModel, java.lang.String tenantId, org.flowable.eventregistry.api.EventRepositoryService eventRepositoryService)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CHANNEL_ID_PREFIX

public static final java.lang.String CHANNEL_ID_PREFIX

See Also:

Constant Field Values

UNSUPPORTED_EVENT_PROCESSING_PIPELINE

protected static final org.flowable.eventregistry.api.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 java.lang.String containerFactoryBeanName

containerFactory

protected MailListenerContainerFactory containerFactory

channelOverrideConfigurations

protected java.util.Map<java.lang.String,MailChannelModelProcessor.ChannelOverrideConfiguration> channelOverrideConfigurations

beanFactory

protected org.springframework.beans.factory.BeanFactory beanFactory

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

MailChannelModelProcessor

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

Method Detail

canProcess

public boolean canProcess(org.flowable.eventregistry.model.ChannelModel channelModel)

Specified by:

canProcess in interface org.flowable.eventregistry.api.ChannelModelProcessor

registerChannelModel

public void registerChannelModel(org.flowable.eventregistry.model.ChannelModel channelModel,
                                 java.lang.String tenantId,
                                 org.flowable.eventregistry.api.EventRegistry eventRegistry,
                                 org.flowable.eventregistry.api.EventRepositoryService eventRepositoryService,
                                 boolean fallbackToDefaultTenant)

Specified by:

registerChannelModel in interface org.flowable.eventregistry.api.ChannelModelProcessor

processInboundModel

protected void processInboundModel(MailInboundChannelModel channelModel,
                                   java.lang.String tenantId,
                                   org.flowable.eventregistry.api.EventRegistry eventRegistry)

registerEndpoint

protected void registerEndpoint(MailListenerEndpoint endpoint,
                                org.springframework.messaging.MessageHandler messageHandler)

createListenerEndpoint

protected MailListenerEndpoint createListenerEndpoint(MailInboundChannelModel model,
                                                      java.lang.String tenantId)

createMessageHandler

protected org.springframework.messaging.MessageHandler createMessageHandler(org.flowable.eventregistry.api.EventRegistry eventRegistry,
                                                                            MailInboundChannelModel channelModel,
                                                                            java.lang.String tenantId)

resolveContainerFactory

protected MailListenerContainerFactory resolveContainerFactory(MailListenerEndpoint endpoint)

getEndpointId

protected java.lang.String getEndpointId(org.flowable.eventregistry.model.ChannelModel channelModel,
                                         java.lang.String tenantId)

resolveAuthenticator

protected javax.mail.Authenticator resolveAuthenticator(MailInboundChannelModel model)

resolveDurationExpression

protected java.time.Duration resolveDurationExpression(java.lang.String value,
                                                       java.lang.String attribute)

resolveExpressionAsBoolean

protected java.lang.Boolean resolveExpressionAsBoolean(java.lang.String value,
                                                       java.lang.String attribute)

resolveExpressionAsLong

protected java.lang.Long resolveExpressionAsLong(java.lang.String value,
                                                 java.lang.String attribute)

resolveUrl

protected java.lang.String resolveUrl(MailInboundChannelModel channelModel)

resolveExpressionAsString

protected java.lang.String resolveExpressionAsString(java.lang.String value,
                                                     java.lang.String attribute)

resolveExpression

protected java.lang.Object resolveExpression(java.lang.String value)

resolve

protected java.lang.String resolve(java.lang.String value)

resolveProperties

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

unregisterChannelModel

public void unregisterChannelModel(org.flowable.eventregistry.model.ChannelModel channelModel,
                                   java.lang.String tenantId,
                                   org.flowable.eventregistry.api.EventRepositoryService eventRepositoryService)

Specified by:

unregisterChannelModel in interface org.flowable.eventregistry.api.ChannelModelProcessor

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

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 java.lang.String getContainerFactoryBeanName()

setContainerFactoryBeanName

public void setContainerFactoryBeanName(java.lang.String containerFactoryBeanName)

getContainerFactory

public MailListenerContainerFactory getContainerFactory()

setContainerFactory

public void setContainerFactory(MailListenerContainerFactory containerFactory)

getChannelOverrideConfigurations

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

setChannelOverrideConfigurations

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