Skip to content

Commit cb6b9f7

Browse files
Add XACKDEL and XDELEX commands support.
Closes #3232 Signed-off-by: viktoriya.kutsarova <viktoriya.kutsarova@redis.com>
1 parent d6cbbe1 commit cb6b9f7

27 files changed

+1855
-270
lines changed

src/main/antora/modules/ROOT/pages/appendix.adoc

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,22 @@ link:https://www.springframework.org/schema/redis/spring-redis-1.0.xsd[Spring Da
184184
|UNSUBSCRIBE |X
185185
|UNWATCH |X
186186
|WATCH |X
187+
|XACK |X
188+
|XACKDEL |X
189+
|XADD |X
190+
|XAUTOCLAIM |X
191+
|XCLAIM |X
192+
|XDEL |X
193+
|XDELEX |X
194+
|XGROUP |X
195+
|XINFO |X
196+
|XLEN |X
197+
|XPENDING |X
198+
|XRANGE |X
199+
|XREAD |X
200+
|XREADGROUP |X
201+
|XREVRANGE |X
202+
|XTRIM |X
187203
|ZADD |X
188204
|ZCARD |X
189205
|ZCOUNT |X

src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2905,6 +2905,18 @@ public Long xDel(String key, RecordId... recordIds) {
29052905
return convertAndReturn(delegate.xDel(serialize(key), recordIds), Converters.identityConverter());
29062906
}
29072907

2908+
@Override
2909+
public List<StreamEntryDeletionResult> xDelEx(String key, XDelOptions options, RecordId... recordIds) {
2910+
return convertAndReturn(delegate.xDelEx(serialize(key), options, recordIds),
2911+
Converters.identityConverter());
2912+
}
2913+
2914+
@Override
2915+
public List<StreamEntryDeletionResult> xAckDel(String key, String group, XDelOptions options, RecordId... recordIds) {
2916+
return convertAndReturn(delegate.xAckDel(serialize(key), group, options, recordIds),
2917+
Converters.identityConverter());
2918+
}
2919+
29082920
@Override
29092921
public String xGroupCreate(String key, ReadOffset readOffset, String group) {
29102922
return convertAndReturn(delegate.xGroupCreate(serialize(key), group, readOffset), Converters.identityConverter());
@@ -3051,6 +3063,16 @@ public Long xDel(byte[] key, RecordId... recordIds) {
30513063
return delegate.xDel(key, recordIds);
30523064
}
30533065

3066+
@Override
3067+
public List<StreamEntryDeletionResult> xDelEx(byte[] key, XDelOptions options, RecordId... recordIds) {
3068+
return delegate.xDelEx(key, options, recordIds);
3069+
}
3070+
3071+
@Override
3072+
public List<StreamEntryDeletionResult> xAckDel(byte[] key, String group, XDelOptions options, RecordId... recordIds) {
3073+
return delegate.xAckDel(key, group, options, recordIds);
3074+
}
3075+
30543076
@Override
30553077
public String xGroupCreate(byte[] key, String groupName, ReadOffset readOffset) {
30563078
return delegate.xGroupCreate(key, groupName, readOffset);

src/main/java/org/springframework/data/redis/connection/DefaultedRedisConnection.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -550,6 +550,20 @@ default Long xDel(byte[] key, RecordId... recordIds) {
550550
return streamCommands().xDel(key, recordIds);
551551
}
552552

553+
/** @deprecated in favor of {@link RedisConnection#streamCommands()}}. */
554+
@Override
555+
@Deprecated
556+
default List<StreamEntryDeletionResult> xDelEx(byte[] key, XDelOptions options, RecordId... recordIds) {
557+
return streamCommands().xDelEx(key, options, recordIds);
558+
}
559+
560+
/** @deprecated in favor of {@link RedisConnection#streamCommands()}}. */
561+
@Override
562+
@Deprecated
563+
default List<StreamEntryDeletionResult> xAckDel(byte[] key, String group, XDelOptions options, RecordId... recordIds) {
564+
return streamCommands().xAckDel(key, group, options, recordIds);
565+
}
566+
553567
/** @deprecated in favor of {@link RedisConnection#streamCommands()}}. */
554568
@Override
555569
@Deprecated
@@ -686,12 +700,14 @@ default Long xTrim(byte[] key, long count) {
686700
return xTrim(key, count, false);
687701
}
688702

703+
/** @deprecated in favor of {@link RedisConnection#streamCommands()}}. */
689704
@Override
690705
@Deprecated
691706
default Long xTrim(byte[] key, long count, boolean approximateTrimming) {
692707
return streamCommands().xTrim(key, count, approximateTrimming);
693708
}
694709

710+
/** @deprecated in favor of {@link RedisConnection#streamCommands()}}. */
695711
@Override
696712
@Deprecated
697713
default Long xTrim(byte[] key, XTrimOptions options) {

0 commit comments

Comments
 (0)