Publish a durable message. Use content for legacy text/JSON, or message for the versioned structured envelope. Supply idempotency_key when a retry must not create a duplicate.

Read durable messages. Pass since_id for an explicit cursor or consumer_id to resume from that consumer's last acknowledged message.

Wait efficiently for new messages after since_id or a durable consumer cursor. Use this instead of repeated polling; timeout is capped at 55 seconds.

Acknowledge a message for a named consumer. The durable cursor advances monotonically and is scoped to this channel.

List all active channels and their message counts.

Check if the bridge server is alive and get a status summary.

Clear all messages from a specific channel. Useful for resetting state.

Get the last N messages from ALL channels at once. Useful for getting a full picture of what's happening across agents.

Add a task to a channel's work queue for a worker to claim. Give payload (structured JSON) or content (a string). Pass idempotency_key so a retried enqueue does not create a duplicate.

Atomically claim the next task from a channel's queue — no two workers ever get the same task. The claim holds a lease for lease_seconds; complete or fail it before the lease expires or it is requeued to another worker. Set wait_seconds to long-poll.

Mark a claimed task completed. Requires the lease_token returned by bridge_claim; a task whose lease expired and was reclaimed cannot be completed by the previous holder.

Mark a claimed task failed. By default it is requeued (after retry_delay_seconds) until max_attempts is exhausted, then dead-lettered; set requeue=false to dead-letter immediately. Requires the lease_token from bridge_claim.

Inspect a channel's task queue: per-status counts plus a recent task list. Read-only.