Job Management
List and inspect jobs, manage the dead-letter queue, and pause queues.
List and inspect jobs, manage the dead-letter queue, and pause queues.
Read and manage individual jobs directly from the FlexiQ handle. For
queue-wide health — stats, per-execution metrics, workers — see
Monitoring.
List<Job> failed = flexiq.listJobs(
JobFilter.builder().status(JobStatus.FAILED).limit(50).build());
flexiq.getJob(id); // Optional<Job>
flexiq.jobErrors(id); // per-attempt error history
flexiq.cancel(id); // cancel a pending jobJobFilter.builder() also filters by queue(name) and task(name) and pages
with offset(n).
flexiq.listDead(50, 0); // newest first: limit, offset
flexiq.listDeadByTask("send_email", 50, 0);
flexiq.retryDead(deadId); // re-enqueue; returns the new job id
flexiq.deleteDead(deadId);
flexiq.purgeDead(olderThanMs);
flexiq.purgeDeadByTask("send_email");
flexiq.purgeCompleted(olderThanMs);Per-queue operations live on the Queue handle from flexiq.queue(name);
the global view stays on the client:
flexiq.queue("default").pause();
flexiq.queue("default").resume();
flexiq.queue("default").isPaused();
flexiq.listPausedQueues();flexiq.registerPeriodic(PeriodicTask.builder("nightly", "report", "0 0 0 * * *").build());
flexiq.listPeriodic(); // every registered task, enabled or paused
flexiq.pausePeriodic("nightly");
flexiq.resumePeriodic("nightly");
flexiq.deletePeriodic("nightly");