public final class PollerSpec extends IntegrationComponentSpec<PollerSpec,PollerMetadata> implements ComponentsRegistration
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public PollerSpec transactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
transactionSynchronizationFactory
- 使用する TransactionSynchronizationFactory。public PollerSpec errorHandler(ErrorHandler errorHandler)
errorHandler
- 使用する ErrorHandler
。taskExecutor(Executor)
public PollerSpec errorChannel(MessageChannel errorChannel)
MessageChannel
を指定します。errorChannel
- 使用する MessageChannel
。MessagePublishingErrorHandler
public PollerSpec errorChannel(StringSE errorChannelName)
MessageChannel
の Bean 名を指定します。errorChannelName
- 使用する MessageChannel
の Bean 名。MessagePublishingErrorHandler
public PollerSpec maxMessagesPerPoll(long maxMessagesPerPoll)
maxMessagesPerPoll
- maxMessagesPerPoll を設定します。PollerMetadata.setMaxMessagesPerPoll(long)
public PollerSpec receiveTimeout(long receiveTimeout)
MessageChannel
でメッセージを待機するタイムアウトをミリ秒単位で指定します。デフォルトは 1000
です。receiveTimeout
- 使用するタイムアウト。PollableChannel.receive(long)
public PollerSpec advice(Advice... advice)
pollingTask
に AOP Advice
を指定します。advice
- 使用する Advice
。public PollerSpec transactional(TransactionManager transactionManager)
TransactionInterceptor
Advice
を、付属の PlatformTransactionManager
で指定し、pollingTask
のデフォルトの DefaultTransactionAttribute
を指定します。transactionManager
- 使用する TransactionManager
。public PollerSpec transactional()
pollingTask
にはデフォルトの PlatformTransactionManager
および DefaultTransactionAttribute
を使用して TransactionInterceptor
Advice
を指定します。public PollerSpec transactional(TransactionInterceptor transactionInterceptor)
transactionInterceptor
- 使用する TransactionInterceptor
。TransactionInterceptorBuilder
public PollerSpec taskExecutor(ExecutorSE taskExecutor)
pollingTask
を実行するには、Executor
SE を指定します。taskExecutor
- 使用する Executor
SE。public PollerSpec sendTimeout(long sendTimeout)
public MapSE<ObjectSE,StringSE> getComponentsToRegister()
ComponentsRegistration
の getComponentsToRegister