クラスの使用
org.springframework.integration.redis.dsl.RedisStreamInboundChannelAdapterSpec
RedisStreamInboundChannelAdapterSpec を使用するパッケージ
org.springframework.integration.redis.dsl 内の RedisStreamInboundChannelAdapterSpec 使用
修飾子と型メソッド説明RedisStreamInboundChannelAdapterSpec.autoAck(boolean autoAck) コンシューマーグループで確認メッセージが読み取られたかどうかを指定します。RedisStreamInboundChannelAdapterSpec.batchSize(int recordsPerPoll) COUNT オプションでバッチサイズを指定してください。RedisStreamInboundChannelAdapterSpec.consumerGroup(StringSE consumerGroup) コンシューマーグループ名を指定してください。RedisStreamInboundChannelAdapterSpec.consumerName(@Nullable StringSE consumerName) コンシューマーの名前を指定してください。RedisStreamInboundChannelAdapterSpec.createConsumerGroup(boolean createConsumerGroup) コンシューマーグループを作成するかどうかを指定します。RedisStreamInboundChannelAdapterSpec.errorResumeFunction(FunctionSE<? super ThrowableSE, ? extends org.reactivestreams.Publisher<VoidSE>> resumeFunction) ストリームのポーリングが失敗した場合に、再開関数を指定します。RedisStreamInboundChannelAdapterSpec.extractPayload(boolean extractPayload) ペイロードを抽出するかどうかを指定します。RedisStreamInboundChannelAdapterSpec.objectMapper(HashMapper<?, ?, ?> hashMapper) hashMapper を指定してください。RedisStreamInboundChannelAdapterSpec.pollTimeout(DurationSE pollTimeout) BLOCK オプションのポーリングタイムアウトを指定してください。RedisStreamInboundChannelAdapterSpec.readOffset(ReadOffset readOffset) メッセージを読み取るオフセットを指定します。RedisStreamInboundChannelAdapterSpec.serializer(RedisSerializationContext.SerializationPair<?> pair) キー、ハッシュキー、ハッシュ値シリアライザを指定します。Redis.streamInboundChannelAdapter(ReactiveRedisConnectionFactory connectionFactory, StringSE streamKey) RedisStreamInboundChannelAdapterSpecを製造するファクトリ。RedisStreamInboundChannelAdapterSpec.streamReceiverOptions(@Nullable StreamReceiver.StreamReceiverOptions<StringSE, ?> streamReceiverOptions) StreamReceiverをカスタマイズするには、streamReceiverOptions を指定してください。RedisStreamInboundChannelAdapterSpec.targetType(ClassSE<?> targetType) ハッシュターゲットの型を指定してください。