Docs / Integrations / Worker Queue

Guard queue workers with deterministic checks.

For each message, call Gvner intent endpoint before writing data or calling external services.

Integration Hub HTTP/Webhook Contract API Reference Support & Launch

Where to hook intent checks

Run intent check at worker handler start, before side effects.

Always call before side effects, not after.

Pass correlation IDs for traceability.

Payload mapping to `/adapters/http/intent`

{
  "tenant_id": "acme",
  "runtime_id": "worker-queue-01",
  "agent_id": "agent-01",
  "intent": "update_customer",
  "requested_scopes": ["update_customers"],
  "tool": "crm",
  "context": {"source": "worker-queue", "workflow": "demo"},
  "requested_budget": 1.0,
  "work_type": "execution",
  "correlation_id": "req-123"
}

Fail-closed behavior

Required: if Gvner is unreachable, returns DENIED, or response is invalid, do not execute. Treat as blocked and log audit context.

Sample wrapper pattern

# in worker handler
decision = guvna_evaluate(intent)
if decision["decision"] != "ALLOWED":
    nack_or_deadletter(message, decision["reason"])
    return
# process message