クラスの使用
org.springframework.data.redis.connection.RedisStreamCommands.XClaimOptions
RedisStreamCommands.XClaimOptions を使用するパッケージ
パッケージ
説明
さまざまな Redis ' ドライバー '/libraries と対話するための低レベルの抽象化を提供する接続パッケージ。
Redis を Spring の概念と統合するためのコアパッケージ。
org.springframework.data.redis.connection 内の RedisStreamCommands.XClaimOptions 使用
修飾子と型メソッド説明RedisStreamCommands.XClaimOptions.force()指定されたストリームレコード ID が有効である限り、保留中のメッセージエントリがまだ存在していなくても、強制的に PEL に作成されます。ReactiveStreamCommands.XClaimCommand.getOptions()RedisStreamCommands.XClaimOptions.idle(DurationSE idleTime) メッセージが最後に配信されてからのアイドル時間を設定します。要求する ID を設定します。要求する ID を設定します。要求する ID を設定します。RedisStreamCommands.XClaimOptions.retryCount(long retryCount) 再試行カウンターを指定された値に設定します。アイドル時間を特定の UNIX 時間（ミリ秒単位）に設定します。型 RedisStreamCommands.XClaimOptions のパラメーターを持つ org.springframework.data.redis.connection のメソッド修飾子と型メソッド説明default ListSE<ByteRecord>DefaultedRedisConnection.xClaim(byte[] key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 使用すべきではありません。DefaultStringRedisConnection.xClaim(byte[] key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) DefaultStringRedisConnection.xClaim(StringSE key, StringSE group, StringSE consumer, RedisStreamCommands.XClaimOptions options) default reactor.core.publisher.Flux<ByteBufferRecord>ReactiveStreamCommands.xClaim(ByteBufferSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。RedisStreamCommands.xClaim(byte[] key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。StringRedisConnection.xClaim(StringSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。DefaultedRedisConnection.xClaimJustId(byte[] key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 使用すべきではありません。DefaultStringRedisConnection.xClaimJustId(byte[] key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) DefaultStringRedisConnection.xClaimJustId(StringSE key, StringSE group, StringSE consumer, RedisStreamCommands.XClaimOptions options) default reactor.core.publisher.Flux<RecordId>ReactiveStreamCommands.xClaimJustId(ByteBufferSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。RedisStreamCommands.xClaimJustId(byte[] key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。StringRedisConnection.xClaimJustId(StringSE key, StringSE group, StringSE newOwner, RedisStreamCommands.XClaimOptions options) 配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。org.springframework.data.redis.core 内の RedisStreamCommands.XClaimOptions 使用
型 RedisStreamCommands.XClaimOptions のパラメーターを持つ org.springframework.data.redis.core のメソッド修飾子と型メソッド説明ReactiveStreamOperations.claim(K key, StringSE consumerGroup, StringSE newOwner, RedisStreamCommands.XClaimOptions xClaimOptions) 新しい所有者がコマンド引数として指定されたコンシューマーになるように、保留中のメッセージの所有権を変更します。StreamOperations.claim(K key, StringSE consumerGroup, StringSE newOwner, RedisStreamCommands.XClaimOptions xClaimOptions) 新しい所有者がコマンド引数として指定されたコンシューマーになるように、保留中のメッセージの所有権を変更します。
RedisCommandsProvider.streamCommands()を推奨。