クラスの使用
org.springframework.data.redis.connection.stream.PendingMessages
PendingMessages を使用するパッケージ
パッケージ
説明
さまざまな Redis ' ドライバー '/libraries と対話するための低レベルの抽象化を提供する接続パッケージ。
Redis ストリームと対話するためのデータ構造とインターフェース。
Redis を Spring の概念と統合するためのコアパッケージ。
org.springframework.data.redis.connection 内の PendingMessages 使用
修飾子と型メソッド説明default PendingMessagesDefaultedRedisConnection.xPending(byte[] key, StringSE groupName, RedisStreamCommands.XPendingOptions options) 使用すべきではありません。DefaultStringRedisConnection.xPending(byte[] key, StringSE groupName, RedisStreamCommands.XPendingOptions options) DefaultStringRedisConnection.xPending(StringSE key, StringSE groupName, StringSE consumer, Range<StringSE> range, LongSE count) DefaultStringRedisConnection.xPending(StringSE key, StringSE groupName, StringSE consumerName, Range<StringSE> range, LongSE count, DurationSE minIdleTime) DefaultStringRedisConnection.xPending(StringSE key, StringSE groupName, Range<StringSE> range, LongSE count) DefaultStringRedisConnection.xPending(StringSE key, StringSE groupName, Range<StringSE> range, LongSE count, DurationSE minIdleTime) DefaultStringRedisConnection.xPending(StringSE key, StringSE groupName, RedisStreamCommands.XPendingOptions options) default PendingMessagesRedisStreamCommands.xPending(byte[] key, StringSE groupName, StringSE consumerName, Range<?> range, LongSE count, DurationSE idle) default PendingMessagesRedisStreamCommands.xPending(byte[] key, StringSE groupName, Range<?> range, LongSE count, DurationSE idle) default PendingMessagesRedisStreamCommands.xPending(byte[] key, Consumer consumer, Range<?> range, LongSE count, DurationSE minIdleTime) default PendingMessagesRedisStreamCommands.xPending(byte @NonNull[] key, @NonNull StringSE groupName, @NonNull StringSE consumerName) 特定のコンシューマーのすべての保留中のメッセージに関する詳細情報を取得しました。default PendingMessagesRedisStreamCommands.xPending(byte @NonNull[] key, @NonNull StringSE groupName, @NonNull StringSE consumerName, @NonNull Range<?> range, @NonNull LongSE count) default PendingMessagesRedisStreamCommands.xPending(byte @NonNull[] key, @NonNull StringSE groupName, @NonNull Range<?> range, @NonNull LongSE count) RedisStreamCommands.xPending(byte @NonNull[] key, @NonNull StringSE groupName, @NonNull RedisStreamCommands.XPendingOptions options) default PendingMessages特定のConsumerのすべての保留中のメッセージに関する詳細情報を取得しました。default PendingMessagesRedisStreamCommands.xPending(byte @NonNull[] key, @NonNull Consumer consumer, @NonNull Range<?> range, @NonNull LongSE count) StringRedisConnection.xPending(@NonNull StringSE key, @NonNull StringSE groupName, @NonNull StringSE consumerName, @NonNull Range<StringSE> range, @NonNull LongSE count) StringRedisConnection.xPending(@NonNull StringSE key, @NonNull StringSE groupName, @NonNull StringSE consumerName, @NonNull Range<StringSE> range, @NonNull LongSE count, @NonNull DurationSE minIdleTime) StringRedisConnection.xPending(@NonNull StringSE key, @NonNull StringSE groupName, @NonNull Range<StringSE> range, @NonNull LongSE count) StringRedisConnection.xPending(@NonNull StringSE key, @NonNull StringSE groupName, @NonNull Range<StringSE> range, @NonNull LongSE count, @NonNull DurationSE minIdleTime) StringRedisConnection.xPending(@NonNull StringSE key, @NonNull StringSE groupName, @NonNull RedisStreamCommands.XPendingOptions options) default PendingMessagesStringRedisConnection.xPending(@NonNull StringSE key, @NonNull Consumer consumer, @NonNull Range<StringSE> range, @NonNull LongSE count) default PendingMessagesStringRedisConnection.xPending(@NonNull StringSE key, @NonNull Consumer consumer, @NonNull Range<StringSE> range, @NonNull LongSE count, @NonNull DurationSE minIdleTime) 型 PendingMessages の引数を持つ型を返す org.springframework.data.redis.connection のメソッド修飾子と型メソッド説明default Mono<PendingMessages> ReactiveStreamCommands.xPending(ByteBufferSE key, StringSE groupName, StringSE consumerName) 特定のコンシューマーのすべての保留中のメッセージに関する詳細情報を取得しました。default Mono<PendingMessages> ReactiveStreamCommands.xPending(ByteBufferSE key, StringSE groupName, StringSE consumerName, Range<?> range, LongSE count) default Mono<PendingMessages> ReactiveStreamCommands.xPending(ByteBufferSE key, StringSE groupName, StringSE consumerName, Range<?> range, LongSE count, DurationSE minIdleTime) default Mono<PendingMessages> ReactiveStreamCommands.xPending(ByteBufferSE key, StringSE groupName, Range<?> range, LongSE count) default Mono<PendingMessages> ReactiveStreamCommands.xPending(ByteBufferSE key, StringSE groupName, Range<?> range, LongSE count, DurationSE minIdleTime) default Mono<PendingMessages> ReactiveStreamCommands.xPending(ByteBufferSE key, Consumer consumer) 特定のConsumerのすべての保留中のメッセージに関する詳細情報を取得しました。default Mono<PendingMessages> ReactiveStreamCommands.xPending(ByteBufferSE key, Consumer consumer, Range<?> range, LongSE count) default Mono<PendingMessages> ReactiveStreamCommands.xPending(ByteBufferSE key, Consumer consumer, Range<?> range, LongSE count, DurationSE minIdleTime) Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand, PendingMessages>> ReactiveStreamCommands.xPending(Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands) org.springframework.data.redis.connection.stream 内の PendingMessages 使用
org.springframework.data.redis.core 内の PendingMessages 使用
修飾子と型メソッド説明StreamOperations.pending(@NonNull K key, @NonNull StringSE group, @NonNull Range<?> range, long count) StreamOperations.pending(@NonNull K key, @NonNull StringSE group, @NonNull Range<?> range, long count, @NonNull DurationSE minIdleTime) default PendingMessages特定のConsumerのすべての保留中のメッセージに関する詳細情報を取得しました。StreamOperations.pending(@NonNull K key, @NonNull Consumer consumer, @NonNull Range<?> range, long count) StreamOperations.pending(@NonNull K key, @NonNull Consumer consumer, @NonNull Range<?> range, long count, @NonNull DurationSE minIdleTime) 型 PendingMessages の引数を持つ型を返す org.springframework.data.redis.core のメソッド修飾子と型メソッド説明ReactiveStreamOperations.pending(@NonNull K key, @NonNull StringSE group, @NonNull Range<?> range, long count) default Mono<PendingMessages> 特定のConsumerのすべての保留中のメッセージに関する詳細情報を取得しました。
RedisCommandsProvider.streamCommands()を推奨。