Skip to content
Registry

iii-queue

v0.21.3-alpha.1

Async job processing with named queues, retries, and dead-letter support.

Deprecated

Renamed to queue. Durable job queues are now a standalone worker — install queue instead of the iii-queue engine builtin.

Use queue instead.

Engine module
Baked into the iii engine; no separate install required.

Install

bash
iii trigger compose::add worker=iii-queue@0.21.3-alpha.1

Run in your project with the iii engine running. Exact versions are immutable and digest-pinned.

Functions9

engine::queue::dlq_messages

Function

Browse DLQ messages

Request
  • limitinteger· uint64min 0

    Maximum number of messages to return (default 50).

  • offsetinteger· uint64min 0

    Number of messages to skip (default 0).

  • topicstringrequired

    Topic or named queue whose dead-letter messages to browse. For a durable topic this is the topic name.

Response
valueunknown

engine::queue::dlq_topics

Function

List DLQ topics with counts

Request
valueunknown
Response
valueunknown

engine::queue::list_topics

Function

List all queue topics

Request
valueunknown
Response
valueunknown

engine::queue::topic_stats

Function

Get stats for a queue topic

Request
  • topicstringrequired

    Topic or named queue to inspect. For a durable topic this is the topic name.

Response
valueunknown

iii-queue::on-config-change

Function

Internal: re-apply the iii-queue configuration when the authoritative configuration entry changes.

Request
valueunknown
Response
valueunknown

iii::durable::publish

Function

Enqueue a message

Request
  • dataunknownrequired

    JSON payload delivered to each subscriber.

  • topicstringrequired

    Topic to publish to. Subscribers registered for this topic receive the message.

Response
valueunknown

iii::queue::discard_message

Function

Discard (purge) a single DLQ message by ID

Request
  • message_idstringrequired

    Identifier of the dead-letter message to redrive (from `engine::queue::dlq_messages`).

  • queuestringrequired

    Queue or topic owning the dead-letter message. For a durable topic this is the topic name.

Response
  • message_idstringrequired
  • queuestringrequired
  • redriveninteger· uint64requiredmin 0

iii::queue::redrive

Function

Redrive all DLQ messages back to the main queue

Request
  • queuestringrequired

    Queue or topic whose dead-letter messages should be moved back to the main queue. For a durable topic this is the topic name.

Response
  • queuestringrequired
  • redriveninteger· uint64requiredmin 0

iii::queue::redrive_message

Function

Redrive a single DLQ message by ID back to the main queue

Request
  • message_idstringrequired

    Identifier of the dead-letter message to redrive (from `engine::queue::dlq_messages`).

  • queuestringrequired

    Queue or topic owning the dead-letter message. For a durable topic this is the topic name.

Response
  • message_idstringrequired
  • queuestringrequired
  • redriveninteger· uint64requiredmin 0

Triggers1

durable:subscriber

Trigger

Queue core module

Invocation
  • condition_function_idstring

    Optional function ID to evaluate before invoking handler

  • queue_configunknown

    Queue-specific subscriber configuration

  • topicstringrequired

    Queue topic to subscribe to

Return
valueunknown

Search the registry

Find workers, kits and executables, or jump to a page.