Skip to content

Commit e911a87

Browse files
author
Nikita Koksharov
committed
javadocs fixed
1 parent dfc49d8 commit e911a87

5 files changed

Lines changed: 23 additions & 51 deletions

File tree

‎redisson/src/main/java/org/redisson/api/RStream.java‎

Lines changed: 4 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -46,23 +46,15 @@ public interface RStream<K, V> extends RStreamAsync<K, V>, RExpirable {
4646
void createGroup(StreamCreateGroupArgs args);
4747

4848
/**
49-
* Creates consumer group by name.
50-
* Only new messages will be available for consumers of this group.
51-
*
52-
* @param groupName - name of group
49+
* Use createGroup(StreamCreateGroupArgs) method instead
5350
*/
51+
@Deprecated
5452
void createGroup(String groupName);
5553

5654
/**
57-
* Creates consumer group by name and Stream Message ID.
58-
* Only new messages after defined stream <code>id</code> will be available for consumers of this group.
59-
* <p>
60-
* {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creation
61-
* {@link StreamMessageId#ALL} is used for all messages added before and after the moment of group creation
62-
*
63-
* @param groupName - name of group
64-
* @param id - Stream Message ID
55+
* Use createGroup(StreamCreateGroupArgs) method instead
6556
*/
57+
@Deprecated
6658
void createGroup(String groupName, StreamMessageId id);
6759

6860
/**

‎redisson/src/main/java/org/redisson/api/RStreamAsync.java‎

Lines changed: 5 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -46,23 +46,15 @@ public interface RStreamAsync<K, V> extends RExpirableAsync {
4646
RFuture<Void> createGroupAsync(StreamCreateGroupArgs args);
4747

4848
/**
49-
* Creates consumer group by name.
50-
*
51-
* @param groupName - name of group
52-
* @return void
49+
* Use createGroupAsync(StreamCreateGroupArgs) method instead
5350
*/
51+
@Deprecated
5452
RFuture<Void> createGroupAsync(String groupName);
55-
53+
5654
/**
57-
* Creates consumer group by name and stream id.
58-
* Only new messages after defined stream <code>id</code> will be available for consumers of this group.
59-
* <p>
60-
* {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creating
61-
*
62-
* @param groupName - name of group
63-
* @param id - stream id
64-
* @return void
55+
* Use createGroupAsync(StreamCreateGroupArgs) method instead
6556
*/
57+
@Deprecated
6658
RFuture<Void> createGroupAsync(String groupName, StreamMessageId id);
6759

6860
/**

‎redisson/src/main/java/org/redisson/api/RStreamReactive.java‎

Lines changed: 5 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -47,23 +47,15 @@ public interface RStreamReactive<K, V> extends RExpirableReactive {
4747
Mono<Void> createGroup(StreamCreateGroupArgs args);
4848

4949
/**
50-
* Creates consumer group by name.
51-
*
52-
* @param groupName - name of group
53-
* @return void
50+
* Use createGroup(StreamCreateGroupArgs) method instead
5451
*/
52+
@Deprecated
5553
Mono<Void> createGroup(String groupName);
56-
54+
5755
/**
58-
* Creates consumer group by name and stream id.
59-
* Only new messages after defined stream <code>id</code> will be available for consumers of this group.
60-
* <p>
61-
* {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creating
62-
*
63-
* @param groupName - name of group
64-
* @param id - stream id
65-
* @return void
56+
* Use createGroup(StreamCreateGroupArgs) method instead
6657
*/
58+
@Deprecated
6759
Mono<Void> createGroup(String groupName, StreamMessageId id);
6860

6961
/**

‎redisson/src/main/java/org/redisson/api/RStreamRx.java‎

Lines changed: 5 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -48,23 +48,15 @@ public interface RStreamRx<K, V> extends RExpirableRx {
4848
Completable createGroup(StreamCreateGroupArgs args);
4949

5050
/**
51-
* Creates consumer group by name.
52-
*
53-
* @param groupName - name of group
54-
* @return void
51+
* Use createGroup(StreamCreateGroupArgs) method instead
5552
*/
53+
@Deprecated
5654
Completable createGroup(String groupName);
57-
55+
5856
/**
59-
* Creates consumer group by name and stream id.
60-
* Only new messages after defined stream <code>id</code> will be available for consumers of this group.
61-
* <p>
62-
* {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creating
63-
*
64-
* @param groupName - name of group
65-
* @param id - stream id
66-
* @return void
57+
* Use createGroup(StreamCreateGroupArgs) method instead
6758
*/
59+
@Deprecated
6860
Completable createGroup(String groupName, StreamMessageId id);
6961

7062
/**

‎redisson/src/main/java/org/redisson/api/stream/StreamCreateGroupArgs.java‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,10 @@ public interface StreamCreateGroupArgs {
4444
* Defines Stream Message ID.
4545
* Only new messages after defined stream <code>id</code> will
4646
* be available for consumers of this group.
47+
* <p>
48+
* {@link StreamMessageId#NEWEST} is used for messages arrived since the moment of group creation
49+
* <p>
50+
* {@link StreamMessageId#ALL} is used for all messages added before and after the moment of group creation
4751
*
4852
* @param id Stream Message ID
4953
* @return arguments object

0 commit comments

Comments
 (0)