クラス RedisStreamInboundChannelAdapterSpec
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<RedisStreamInboundChannelAdapterSpec, ReactiveRedisStreamMessageProducer>
org.springframework.integration.dsl.MessageProducerSpec<RedisStreamInboundChannelAdapterSpec, ReactiveRedisStreamMessageProducer>
org.springframework.integration.redis.dsl.RedisStreamInboundChannelAdapterSpec
- 実装済みのインターフェース一覧:
DisposableBean, FactoryBean<ReactiveRedisStreamMessageProducer>, InitializingBean, Lifecycle, Phased, SmartLifecycle
public class RedisStreamInboundChannelAdapterSpec
extends MessageProducerSpec<RedisStreamInboundChannelAdapterSpec, ReactiveRedisStreamMessageProducer>
- 導入:
- 7.1
- 作成者:
- Jiandong Ma
フィールド概要
クラス IntegrationComponentSpec から継承されたフィールド
logger, PARSER, targetインターフェース FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTEインターフェース SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクター概要
コンストラクター修飾子コンストラクター説明protectedRedisStreamInboundChannelAdapterSpec(ReactiveRedisConnectionFactory connectionFactory, StringSE streamKey) 方法の概要
修飾子と型メソッド説明autoAck(boolean autoAck) コンシューマーグループで確認メッセージが読み取られたかどうかを指定します。batchSize(int recordsPerPoll) COUNT オプションでバッチサイズを指定してください。consumerGroup(StringSE consumerGroup) コンシューマーグループ名を指定してください。consumerName(@Nullable StringSE consumerName) コンシューマーの名前を指定してください。createConsumerGroup(boolean createConsumerGroup) コンシューマーグループを作成するかどうかを指定します。errorResumeFunction(FunctionSE<? super ThrowableSE, ? extends org.reactivestreams.Publisher<VoidSE>> resumeFunction) ストリームのポーリングが失敗した場合に、再開関数を指定します。extractPayload(boolean extractPayload) ペイロードを抽出するかどうかを指定します。objectMapper(HashMapper<?, ?, ?> hashMapper) hashMapper を指定してください。pollTimeout(DurationSE pollTimeout) BLOCK オプションのポーリングタイムアウトを指定してください。readOffset(ReadOffset readOffset) メッセージを読み取るオフセットを指定します。キー、ハッシュキー、ハッシュ値シリアライザを指定します。streamReceiverOptions(@Nullable StreamReceiver.StreamReceiverOptions<StringSE, ?> streamReceiverOptions) StreamReceiverをカスタマイズするには、streamReceiverOptions を指定してください。targetType(ClassSE<?> targetType) ハッシュターゲットの型を指定してください。クラス 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
コンストラクターの詳細
RedisStreamInboundChannelAdapterSpec
protected RedisStreamInboundChannelAdapterSpec(ReactiveRedisConnectionFactory connectionFactory, StringSE streamKey)
方法の詳細
readOffset
メッセージを読み取るオフセットを指定します。- パラメーター:
readOffset- readOffset- 戻り値:
- スペック
- 関連事項:
extractPayload
ペイロードを抽出するかどうかを指定します。- パラメーター:
extractPayload- extractPayload- 戻り値:
- スペック
- 関連事項:
autoAck
コンシューマーグループで確認メッセージが読み取られたかどうかを指定します。- パラメーター:
autoAck- 承認オプション- 戻り値:
- スペック
- 関連事項:
consumerGroup
コンシューマーグループ名を指定してください。- パラメーター:
consumerGroup- consumerGroup- 戻り値:
- スペック
- 関連事項:
consumerName
コンシューマーの名前を指定してください。- パラメーター:
consumerName- consumerName- 戻り値:
- スペック
- 関連事項:
createConsumerGroup
コンシューマーグループを作成するかどうかを指定します。- パラメーター:
createConsumerGroup- createConsumerGroup- 戻り値:
- スペック
- 関連事項:
streamReceiverOptions
public RedisStreamInboundChannelAdapterSpec streamReceiverOptions(@Nullable StreamReceiver.StreamReceiverOptions<StringSE, ?> streamReceiverOptions) StreamReceiverをカスタマイズするには、streamReceiverOptions を指定してください。- パラメーター:
streamReceiverOptions- streamReceiverOptions- 戻り値:
- スペック
- 関連事項:
pollTimeout
BLOCK オプションのポーリングタイムアウトを指定してください。- パラメーター:
pollTimeout- pollTimeout- 戻り値:
- スペック
- 関連事項:
batchSize
COUNT オプションでバッチサイズを指定してください。- パラメーター:
recordsPerPoll- recordsPerPoll- 戻り値:
- スペック
- 関連事項:
errorResumeFunction
public RedisStreamInboundChannelAdapterSpec errorResumeFunction(FunctionSE<? super ThrowableSE, ? extends org.reactivestreams.Publisher<VoidSE>> resumeFunction) ストリームのポーリングが失敗した場合に、再開関数を指定します。- パラメーター:
resumeFunction- resumeFunction- 戻り値:
- スペック
- 関連事項:
serializer
public RedisStreamInboundChannelAdapterSpec serializer(RedisSerializationContext.SerializationPair<?> pair) キー、ハッシュキー、ハッシュ値シリアライザを指定します。- パラメーター:
pair- そのペア- 戻り値:
- スペック
- 関連事項:
targetType
ハッシュターゲットの型を指定してください。- パラメーター:
targetType- targetType- 戻り値:
- スペック
- 関連事項:
objectMapper
hashMapper を指定してください。- パラメーター:
hashMapper- hashMapper- 戻り値:
- スペック
- 関連事項: