Changed RsStreamConsumer>>autoClaimIdling to use auto claim API with …

…IDS only option
mumez · Sep 1, 2024 · 28532dc · 28532dc
1 parent eb7fccb
commit 28532dc
Show file tree

Hide file tree

Showing 6 changed files with 16 additions and 1 deletion.
diff --git a/...itory/RediStick-Stream-Objects.package/RsStreamConsumer.class/instance/autoClaimIdling.st b/...itory/RediStick-Stream-Objects.package/RsStreamConsumer.class/instance/autoClaimIdling.st
@@ -1,3 +1,3 @@
 claiming
 autoClaimIdling
-	^ self autoClaimIdleMoreThan: self settings claimMinIdleMilliseconds
+	^ self autoClaimIdsIdleMoreThan: self settings claimMinIdleMilliseconds
diff --git a/...-Stream-Objects.package/RsStreamConsumer.class/instance/autoClaimIdsFrom.idleMoreThan..st b/...-Stream-Objects.package/RsStreamConsumer.class/instance/autoClaimIdsFrom.idleMoreThan..st
@@ -0,0 +1,3 @@
+claiming
+autoClaimIdsFrom: start idleMoreThan: milliseconds
+	^ self autoClaimIdsFrom: start idleMoreThan: milliseconds atMost: self settings claimReadChunkSize 
diff --git a/...-Objects.package/RsStreamConsumer.class/instance/autoClaimIdsFrom.idleMoreThan.atMost..st b/...-Objects.package/RsStreamConsumer.class/instance/autoClaimIdsFrom.idleMoreThan.atMost..st
@@ -0,0 +1,3 @@
+claiming
+autoClaimIdsFrom: start idleMoreThan: milliseconds atMost: count
+	^ self group autoClaimIdsFrom: start idleMoreThan: milliseconds atMost: count on: self name
diff --git a/...Stick-Stream-Objects.package/RsStreamConsumer.class/instance/autoClaimIdsIdleMoreThan..st b/...Stick-Stream-Objects.package/RsStreamConsumer.class/instance/autoClaimIdsIdleMoreThan..st
@@ -0,0 +1,3 @@
+claiming
+autoClaimIdsIdleMoreThan: milliseconds
+	^ self autoClaimIdsFrom: RsStreamMessageId zero idleMoreThan: milliseconds
diff --git a/...ry/RediStick-Stream-Objects.package/RsStreamConsumer.class/instance/autoClaimIdsIdling.st b/...ry/RediStick-Stream-Objects.package/RsStreamConsumer.class/instance/autoClaimIdsIdling.st
@@ -0,0 +1,3 @@
+claiming
+autoClaimIdsIdling
+	^ self autoClaimIdsIdleMoreThan: self settings claimMinIdleMilliseconds
diff --git a/....package/RsStreamConsumerGroup.class/instance/autoClaimIdsFrom.idleMoreThan.atMost.on..st b/....package/RsStreamConsumerGroup.class/instance/autoClaimIdsFrom.idleMoreThan.atMost.on..st
@@ -0,0 +1,3 @@
+claiming
+autoClaimIdsFrom: start idleMoreThan: milliseconds atMost: count on: consumerName
+	^ self endpoint xAutoClaim: self streamName group: self name consumer: consumerName minIdleTime: milliseconds start: start count: count idsOnly: true