public final class PollerSpec extends IntegrationComponentSpec<PollerSpec,PollerMetadata> implements ComponentsRegistration
PARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic PollerSpec transactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
transactionSynchronizationFactory - 使用する TransactionSynchronizationFactory。public PollerSpec errorHandler(ErrorHandler errorHandler)
errorHandler - 使用する ErrorHandler。taskExecutor(Executor)public PollerSpec errorChannel(MessageChannel errorChannel)
MessageChannel を指定します。errorChannel - 使用する MessageChannel。MessagePublishingErrorHandlerpublic PollerSpec errorChannel(StringSE errorChannelName)
MessageChannel の Bean 名を指定します。errorChannelName - 使用する MessageChannel の Bean 名。MessagePublishingErrorHandlerpublic 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。TransactionInterceptorBuilderpublic PollerSpec taskExecutor(ExecutorSE taskExecutor)
pollingTask を実行するには、ExecutorSE を指定します。taskExecutor - 使用する ExecutorSE。public PollerSpec sendTimeout(long sendTimeout)
public MapSE<ObjectSE,StringSE> getComponentsToRegister()
ComponentsRegistration の getComponentsToRegister