クラス PollingConsumer
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.AbstractPollingEndpoint
org.springframework.integration.endpoint.PollingConsumer
- 実装されているすべてのインターフェース:
Aware、BeanClassLoaderAware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ComponentSourceAware、ExpressionCapable、IntegrationConsumer、NamedComponent、ManageableLifecycle、ManageableSmartLifecycle
MessageHandler 実装を PollableChannel に接続するメッセージエンドポイント。- 作成者:
- Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan
フィールドのサマリー
フィールドクラス org.springframework.integration.endpoint.AbstractPollingEndpoint から継承されたフィールド
DEFAULT_POLLING_PERIODクラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
lifecycleLockクラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected voiddoStart()サブクラスは、開始動作でこのメソッドを実装する必要があります。protected voiddoStop()サブクラスは、停止動作でこのメソッドを実装する必要があります。コンシューマーのハンドラーを返します。入力チャンネルを返します。出力チャネルを返します（null の場合もあります）。protected ObjectSEprotected StringSEリソースがIntegrationResourceHolderの属性として使用可能になるキーを返します。protected ObjectSEトランザクション同期を使用するときにバインドするリソース (MessageSource など) を返します。protected voidhandleMessage(Message<?> message) メッセージを処理します。protected booleanprotected Message<?> 次のメッセージを取得します（利用可能な場合）。protected voidsetReceiveMessageSource(ObjectSE source) voidsetReceiveTimeout(long receiveTimeout) クラス org.springframework.integration.endpoint.AbstractPollingEndpoint から継承されたメソッド
applyReceiveOnlyAdviceChain, donePollingTask, getBeanClassLoader, getDefaultErrorChannel, getMaxMessagesPerPoll, getPollingFlux, getTaskExecutor, isReceiveOnlyAdvice, isSyncExecutor, messageReceived, onInit, setAdviceChain, setBeanClassLoader, setErrorHandler, setMaxMessagesPerPoll, setTaskExecutor, setTransactionSynchronizationFactory, setTriggerクラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopクラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getComponentType, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName, getComponentType
フィールドの詳細
DEFAULT_RECEIVE_TIMEOUT
public static final long DEFAULT_RECEIVE_TIMEOUTデフォルトの受信タイムアウトは 1000L ミリ秒です。- 関連事項:
コンストラクターの詳細
PollingConsumer
メソッドの詳細
setReceiveTimeout
public void setReceiveTimeout(long receiveTimeout) getInputChannel
インターフェースからコピーされた説明:IntegrationConsumer入力チャンネルを返します。- 次で指定:
- インターフェース
IntegrationConsumerのgetInputChannel - 戻り値:
- 入力チャンネル。
getOutputChannel
インターフェースからコピーされた説明:IntegrationConsumer出力チャネルを返します（null の場合もあります）。- 次で指定:
- インターフェース
IntegrationConsumerのgetOutputChannel - 戻り値:
- 出力チャンネル。
getHandler
インターフェースからコピーされた説明:IntegrationConsumerコンシューマーのハンドラーを返します。- 次で指定:
- インターフェース
IntegrationConsumerのgetHandler - 戻り値:
- ハンドラー。
getReceiveMessageSource
- オーバーライド:
- クラス
AbstractPollingEndpointのgetReceiveMessageSource
setReceiveMessageSource
- オーバーライド:
- クラス
AbstractPollingEndpointのsetReceiveMessageSource
isReactive
protected boolean isReactive()- オーバーライド:
- クラス
AbstractPollingEndpointのisReactive
doStart
protected void doStart()クラスからコピーされた説明:AbstractEndpointサブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLockを保持しているときに呼び出されます。- オーバーライド:
- クラス
AbstractPollingEndpointのdoStart
doStop
protected void doStop()クラスからコピーされた説明:AbstractEndpointサブクラスは、停止動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLockを保持しているときに呼び出されます。- オーバーライド:
- クラス
AbstractPollingEndpointのdoStop
handleMessage
クラスからコピーされた説明:AbstractPollingEndpointメッセージを処理します。- 次で指定:
- クラス
AbstractPollingEndpointのhandleMessage - パラメーター:
message- メッセージ。
receiveMessage
クラスからコピーされた説明:AbstractPollingEndpoint次のメッセージを取得します（利用可能な場合）。すぐに利用できるメッセージがない場合は、null を返す場合があります。- 次で指定:
- クラス
AbstractPollingEndpointのreceiveMessage - 戻り値:
- メッセージまたは null。
getResourceToBind
クラスからコピーされた説明:AbstractPollingEndpointトランザクション同期を使用するときにバインドするリソース (MessageSource など) を返します。- オーバーライド:
- クラス
AbstractPollingEndpointのgetResourceToBind - 戻り値:
- リソース。トランザクションの同期が不要な場合は null。
getResourceKey
クラスからコピーされた説明:AbstractPollingEndpointリソースがIntegrationResourceHolderの属性として使用可能になるキーを返します。デフォルトのExpressionEvaluatingTransactionSynchronizationProcessorは、この属性を SpEL 式の変数として使用できるようにします。- オーバーライド:
- クラス
AbstractPollingEndpointのgetResourceKey - 戻り値:
- キー、またはリソースを属性として使用可能にしない場合は null（デフォルト）。