クラス RedisQueueInboundChannelAdapterSpec
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<RedisQueueInboundChannelAdapterSpec, RedisQueueMessageDrivenEndpoint>
org.springframework.integration.dsl.MessageProducerSpec<RedisQueueInboundChannelAdapterSpec, RedisQueueMessageDrivenEndpoint>
org.springframework.integration.redis.dsl.RedisQueueInboundChannelAdapterSpec
- 実装済みのインターフェース一覧:
DisposableBean, FactoryBean<RedisQueueMessageDrivenEndpoint>, InitializingBean, Lifecycle, Phased, SmartLifecycle
public class RedisQueueInboundChannelAdapterSpec
extends MessageProducerSpec<RedisQueueInboundChannelAdapterSpec, RedisQueueMessageDrivenEndpoint>
- 導入:
- 7.1
- 作成者:
- Jiandong Ma
フィールド概要
クラス IntegrationComponentSpec から継承されたフィールド
logger, PARSER, targetインターフェース FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTEインターフェース SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクター概要
コンストラクター修飾子コンストラクター説明protectedRedisQueueInboundChannelAdapterSpec(StringSE queueName, RedisConnectionFactory connectionFactory) 方法の概要
修飾子と型メソッド説明expectMessage(boolean expectMessage) Redis キューからのデータにメッセージインスタンス全体が含まれることを想定しているかどうかを指定します。receiveDuration(DurationSE receiveTimeout) Redis キューから Redis メッセージを待機する "pop" 操作のタイムアウトを指定します。receiveTimeout(long receiveTimeout) Redis キューから Redis メッセージを待機する "pop" 操作のタイムアウトを指定します。recoveryInterval(long recoveryInterval) "pop" 操作で例外が発生した後、基となるリスニングタスクがスリープする時間をミリ秒単位で指定します。rightPop(boolean rightPop) Redis キューからメッセージを読み取るには、"right pop" または "left pop" を指定してください。serializer(RedisSerializer<?> serializer) Redis メッセージの本文を逆直列化するには、RedisSerializer を指定します。taskExecutor(ExecutorSE taskExecutor) 基となるリスニングタスクには、ExecutorSE を指定してください。クラス MessageProducerSpec から継承されたメソッド
autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, observationConvention, outputChannel, outputChannel, phase, role, sendTimeout, shouldTrackクラス IntegrationComponentSpec から継承されたメソッド
_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース FactoryBean から継承されたメソッド
isSingletonインターフェース SmartLifecycle から継承されたメソッド
isPauseable
コンストラクターの詳細
RedisQueueInboundChannelAdapterSpec
protected RedisQueueInboundChannelAdapterSpec(StringSE queueName, RedisConnectionFactory connectionFactory)
方法の詳細
serializer
Redis メッセージの本文を逆直列化するには、RedisSerializer を指定します。- パラメーター:
serializer- シリアライザー- 戻り値:
- スペック
- 関連事項:
expectMessage
Redis キューからのデータにメッセージインスタンス全体が含まれることを想定しているかどうかを指定します。- パラメーター:
expectMessage- expectMessage- 戻り値:
- スペック
- 関連事項:
receiveDuration
Redis キューから Redis メッセージを待機する "pop" 操作のタイムアウトを指定します。- パラメーター:
receiveTimeout- receiveTimeout- 戻り値:
- スペック
- 関連事項:
receiveTimeout
Redis キューから Redis メッセージを待機する "pop" 操作のタイムアウトを指定します。- パラメーター:
receiveTimeout- receiveTimeout- 戻り値:
- スペック
- 関連事項:
taskExecutor
基となるリスニングタスクには、ExecutorSE を指定してください。- パラメーター:
taskExecutor- taskExecutor- 戻り値:
- スペック
- 関連事項:
recoveryInterval
"pop" 操作で例外が発生した後、基となるリスニングタスクがスリープする時間をミリ秒単位で指定します。- パラメーター:
recoveryInterval- recoveryInterval- 戻り値:
- スペック
- 関連事項:
rightPop
Redis キューからメッセージを読み取るには、"right pop" または "left pop" を指定してください。- パラメーター:
rightPop- rightPop- 戻り値:
- スペック
- 関連事項: