diff --git a/redisson/src/main/java/org/redisson/api/RStream.java b/redisson/src/main/java/org/redisson/api/RStream.java index c77cf3bb3..659e49c24 100644 --- a/redisson/src/main/java/org/redisson/api/RStream.java +++ b/redisson/src/main/java/org/redisson/api/RStream.java @@ -46,23 +46,15 @@ public interface RStream extends RStreamAsync, RExpirable { void createGroup(StreamCreateGroupArgs args); /** - * Creates consumer group by name. - * Only new messages will be available for consumers of this group. - * - * @param groupName - name of group + * Use createGroup(StreamCreateGroupArgs) method instead */ + @Deprecated void createGroup(String groupName); /** - * Creates consumer group by name and Stream Message ID. - * Only new messages after defined stream id will be available for consumers of this group. - *

- * {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creation - * {@link StreamMessageId#ALL} is used for all messages added before and after the moment of group creation - * - * @param groupName - name of group - * @param id - Stream Message ID + * Use createGroup(StreamCreateGroupArgs) method instead */ + @Deprecated void createGroup(String groupName, StreamMessageId id); /** diff --git a/redisson/src/main/java/org/redisson/api/RStreamAsync.java b/redisson/src/main/java/org/redisson/api/RStreamAsync.java index 4f49c8664..5d718edf4 100644 --- a/redisson/src/main/java/org/redisson/api/RStreamAsync.java +++ b/redisson/src/main/java/org/redisson/api/RStreamAsync.java @@ -46,23 +46,15 @@ public interface RStreamAsync extends RExpirableAsync { RFuture createGroupAsync(StreamCreateGroupArgs args); /** - * Creates consumer group by name. - * - * @param groupName - name of group - * @return void + * Use createGroupAsync(StreamCreateGroupArgs) method instead */ + @Deprecated RFuture createGroupAsync(String groupName); - + /** - * Creates consumer group by name and stream id. - * Only new messages after defined stream id will be available for consumers of this group. - *

- * {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creating - * - * @param groupName - name of group - * @param id - stream id - * @return void + * Use createGroupAsync(StreamCreateGroupArgs) method instead */ + @Deprecated RFuture createGroupAsync(String groupName, StreamMessageId id); /** diff --git a/redisson/src/main/java/org/redisson/api/RStreamReactive.java b/redisson/src/main/java/org/redisson/api/RStreamReactive.java index cbef6fafc..c0cc32449 100644 --- a/redisson/src/main/java/org/redisson/api/RStreamReactive.java +++ b/redisson/src/main/java/org/redisson/api/RStreamReactive.java @@ -47,23 +47,15 @@ public interface RStreamReactive extends RExpirableReactive { Mono createGroup(StreamCreateGroupArgs args); /** - * Creates consumer group by name. - * - * @param groupName - name of group - * @return void + * Use createGroup(StreamCreateGroupArgs) method instead */ + @Deprecated Mono createGroup(String groupName); - + /** - * Creates consumer group by name and stream id. - * Only new messages after defined stream id will be available for consumers of this group. - *

- * {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creating - * - * @param groupName - name of group - * @param id - stream id - * @return void + * Use createGroup(StreamCreateGroupArgs) method instead */ + @Deprecated Mono createGroup(String groupName, StreamMessageId id); /** diff --git a/redisson/src/main/java/org/redisson/api/RStreamRx.java b/redisson/src/main/java/org/redisson/api/RStreamRx.java index b34bfdd7a..589c53c31 100644 --- a/redisson/src/main/java/org/redisson/api/RStreamRx.java +++ b/redisson/src/main/java/org/redisson/api/RStreamRx.java @@ -48,23 +48,15 @@ public interface RStreamRx extends RExpirableRx { Completable createGroup(StreamCreateGroupArgs args); /** - * Creates consumer group by name. - * - * @param groupName - name of group - * @return void + * Use createGroup(StreamCreateGroupArgs) method instead */ + @Deprecated Completable createGroup(String groupName); - + /** - * Creates consumer group by name and stream id. - * Only new messages after defined stream id will be available for consumers of this group. - *

- * {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creating - * - * @param groupName - name of group - * @param id - stream id - * @return void + * Use createGroup(StreamCreateGroupArgs) method instead */ + @Deprecated Completable createGroup(String groupName, StreamMessageId id); /** diff --git a/redisson/src/main/java/org/redisson/api/stream/StreamCreateGroupArgs.java b/redisson/src/main/java/org/redisson/api/stream/StreamCreateGroupArgs.java index e19bbacfb..5b723e9ae 100644 --- a/redisson/src/main/java/org/redisson/api/stream/StreamCreateGroupArgs.java +++ b/redisson/src/main/java/org/redisson/api/stream/StreamCreateGroupArgs.java @@ -44,6 +44,10 @@ public interface StreamCreateGroupArgs { * Defines Stream Message ID. * Only new messages after defined stream id will * be available for consumers of this group. + *

+ * {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creation + *

+ * {@link StreamMessageId#ALL} is used for all messages added before and after the moment of group creation * * @param id Stream Message ID * @return arguments object