public class ImapIdleChannelAdapterSpec extends MessageProducerSpec<ImapIdleChannelAdapterSpec,ImapIdleChannelAdapter> implements ComponentsRegistration
Modifier and Type | Field and Description |
---|---|
protected boolean |
externalReceiver |
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, outputChannel, outputChannel, phase, sendTimeout, shouldTrack
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
public ImapIdleChannelAdapterSpec selectorExpression(String selectorExpression)
MimeMessage
which should return a boolean
result (true means select the message).selectorExpression
- the selectorExpression.public ImapIdleChannelAdapterSpec selectorExpression(Expression selectorExpression)
Expression
to select messages. The root object for the expression
evaluation is a MimeMessage
which should return a boolean
result (true means select the message).selectorExpression
- the selectorExpression.public ImapIdleChannelAdapterSpec selector(java.util.function.Function<MimeMessage,Boolean> selectorFunction)
Function
to select messages. The argument for the function
is a MimeMessage
; apply
returns a boolean
result (true means select the message).selectorFunction
- the selectorFunction.FunctionExpression
public ImapIdleChannelAdapterSpec session(Session session)
Session
to use.session
- the session.AbstractMailReceiver.setSession(Session)
public ImapIdleChannelAdapterSpec javaMailProperties(Properties javaMailProperties)
javaMailProperties
- the javaMailProperties.AbstractMailReceiver.setJavaMailProperties(Properties)
public ImapIdleChannelAdapterSpec javaMailProperties(java.util.function.Consumer<PropertiesBuilder> configurer)
javaMailProperties
by invoking a Consumer
callback which
is invoked with a PropertiesBuilder
.configurer
- the configurer.AbstractMailReceiver.setJavaMailProperties(Properties)
public ImapIdleChannelAdapterSpec javaMailAuthenticator(Authenticator javaMailAuthenticator)
javaMailAuthenticator
- the javaMailAuthenticator.AbstractMailReceiver.setJavaMailAuthenticator(Authenticator)
public ImapIdleChannelAdapterSpec maxFetchSize(int maxFetchSize)
maxFetchSize
- the maxFetchSize.AbstractMailReceiver.setMaxFetchSize(int)
public ImapIdleChannelAdapterSpec shouldDeleteMessages(boolean shouldDeleteMessages)
shouldDeleteMessages
- the shouldDeleteMessages.AbstractMailReceiver.setShouldDeleteMessages(boolean)
public ImapIdleChannelAdapterSpec searchTermStrategy(SearchTermStrategy searchTermStrategy)
searchTermStrategy
- the searchTermStrategy.ImapMailReceiver.setSearchTermStrategy(SearchTermStrategy)
public ImapIdleChannelAdapterSpec shouldMarkMessagesAsRead(boolean shouldMarkMessagesAsRead)
shouldMarkMessagesAsRead
- the shouldMarkMessagesAsRead.ImapMailReceiver.setShouldMarkMessagesAsRead(Boolean)
public ImapIdleChannelAdapterSpec userFlag(String userFlag)
userFlag
- the flag.AbstractMailReceiver.setUserFlag(String)
public ImapIdleChannelAdapterSpec headerMapper(HeaderMapper<MimeMessage> headerMapper)
MimeMessage
, when provided, the headers are mapped and the payload is
the MimeMessage
content.headerMapper
- the header mapper.AbstractMailReceiver.setUserFlag(String)
,
embeddedPartsAsBytes(boolean)
public ImapIdleChannelAdapterSpec embeddedPartsAsBytes(boolean embeddedPartsAsBytes)
Part
(e.g Message
or
Multipart
content is rendered as a byte[] in the payload.
Otherwise, leave as a Part
. These objects are not suitable for
downstream serialization. Default: true.
This has no effect if there is no header mapper, in that case the payload is the
MimeMessage
.
embeddedPartsAsBytes
- the embeddedPartsAsBytes to set.headerMapper(HeaderMapper)
public ImapIdleChannelAdapterSpec autoCloseFolder(boolean autoCloseFolder)
false
, the folder is not closed automatically after a fetch.
It is the target application's responsibility to close it using the
IntegrationMessageHeaderAccessor.CLOSEABLE_RESOURCE
header
from the message produced by this channel adapter.autoCloseFolder
- set to false
to keep folder opened.AbstractMailReceiver.setAutoCloseFolder(boolean)
public ImapIdleChannelAdapterSpec transactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
TransactionSynchronizationFactory
. Usually used to synchronize
message deletion with some external transaction manager.transactionSynchronizationFactory
- the transactionSynchronizationFactory.public ImapIdleChannelAdapterSpec adviceChain(Advice... adviceChain)
Advice
objects for message delivery, applied to
the downstream flow.adviceChain
- the advice chain.@Deprecated public ImapIdleChannelAdapterSpec transactional(PlatformTransactionManager transactionManager)
transactional(TransactionManager)
TransactionInterceptor
Advice
with the provided
PlatformTransactionManager
and default
DefaultTransactionAttribute
for the downstream flow.transactionManager
- the PlatformTransactionManager
to use.public ImapIdleChannelAdapterSpec transactional(TransactionManager transactionManager)
TransactionInterceptor
Advice
with the provided
TransactionManager
and default
DefaultTransactionAttribute
for the downstream flow.transactionManager
- the TransactionManager
to use.public ImapIdleChannelAdapterSpec transactional(TransactionInterceptor transactionInterceptor)
TransactionInterceptor
Advice
for the
downstream flow.transactionInterceptor
- the TransactionInterceptor
to use.TransactionInterceptorBuilder
public ImapIdleChannelAdapterSpec transactional()
TransactionInterceptor
Advice
with default
PlatformTransactionManager
and
DefaultTransactionAttribute
for the
downstream flow.public ImapIdleChannelAdapterSpec sendingTaskExecutor(Executor sendingTaskExecutor)
sendingTaskExecutor
- the sendingTaskExecutor.ImapIdleChannelAdapter.setSendingTaskExecutor(Executor)
public ImapIdleChannelAdapterSpec shouldReconnectAutomatically(boolean shouldReconnectAutomatically)
shouldReconnectAutomatically
- the shouldReconnectAutomatically.ImapIdleChannelAdapter.setShouldReconnectAutomatically(boolean)
public ImapIdleChannelAdapterSpec cancelIdleInterval(long interval)
interval
- the interval.ImapMailReceiver.setCancelIdleInterval(long)
public Map<Object,String> getComponentsToRegister()
getComponentsToRegister
in interface ComponentsRegistration