Package app.ductape.sdk.jobs

Class RedissonJobQueueAdapter

java.lang.Object

app.ductape.sdk.jobs.RedissonJobQueueAdapter

All Implemented Interfaces:

JobsService.JobQueueAdapter

public final class RedissonJobQueueAdapter
extends Object
implements JobsService.JobQueueAdapter

Redisson-native queue adapter that mirrors the queue touchpoints used by TS JobsService (which is BullMQ-backed in TS). Java is Redisson-native by design — this adapter does not speak the BullMQ wire protocol; it provides equivalent functional semantics on top of Redisson primitives (RScoredSortedSet, RMap, distributed locks).

Touchpoints kept aligned with TS callers:

• add(type, input, options) — repeat.every / repeat.cron supported with repeat.limit / repeat.endDate guards (recurrence reschedules on ack).
• get/remove by jobId.
• removeRepeatableByKey(repeatableKey).
• claimDueJobsWithLock / ack / fail — worker-token leasing for the Ductape.monitor() loop, with stale-lock reclamation (functional equivalent of BullMQ stalled-job recovery).

Retry/backoff is owned by TS job-state logic in ProcessorService/JobsService, not by this adapter — the fail path here only reschedules recurring jobs and re-leases stalled work, never silently increments attempts.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	RedissonJobQueueAdapter.LockedJob

Constructor Summary

Constructors

Constructor	Description
RedissonJobQueueAdapter(org.redisson.api.RedissonClient redisson, String workspaceId)
RedissonJobQueueAdapter(org.redisson.api.RedissonClient redisson, String workspaceId, String queueName)

Method Summary

Modifier and Type	Method	Description
void	ack(String jobId, String workerToken)
void	add(String jobId, String type, Map<String,Object> input, Map<String,Object> options)
List<Map<String,Object>>	claimDueJobs(int limit)
List<RedissonJobQueueAdapter.LockedJob>	claimDueJobsWithLock(int limit, long lockMs)
void	fail(String jobId, String workerToken, String error, Long retryDelayMs)
void	remove(String jobId)
void	removeRepeatableByKey(String repeatableKey)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RedissonJobQueueAdapter

public RedissonJobQueueAdapter(org.redisson.api.RedissonClient redisson,
 String workspaceId)

RedissonJobQueueAdapter

public RedissonJobQueueAdapter(org.redisson.api.RedissonClient redisson,
 String workspaceId,
 String queueName)

Method Details

add

public void add(String jobId,
 String type,
 Map<String,Object> input,
 Map<String,Object> options)

Specified by:

add in interface JobsService.JobQueueAdapter

remove

public void remove(String jobId)

Specified by:

remove in interface JobsService.JobQueueAdapter

claimDueJobs

public List<Map<String,Object>> claimDueJobs(int limit)

claimDueJobsWithLock

public List<RedissonJobQueueAdapter.LockedJob> claimDueJobsWithLock(int limit,
 long lockMs)

ack

public void ack(String jobId,
 String workerToken)

fail

public void fail(String jobId,
 String workerToken,
 String error,
 Long retryDelayMs)

removeRepeatableByKey

public void removeRepeatableByKey(String repeatableKey)

Specified by:

removeRepeatableByKey in interface JobsService.JobQueueAdapter