Channels (Pub/Sub)

• tickets:new
• tickets:ai:analysis:{ticketId}
• alerts:new
• alerts:ai:analysis:{alertId}
• emails:inbound
• emails:ai:analysis:{emailId}
• remediation:new
• remediation:ai:analysis:{eventId}
• contracts:policy
• contracts:ai:analysis:{contractId}
• dashboard:events
• jobs:queue
• jobs:progress:{jobId}
• notifications:new
• notifications:sent

Lists/Sets/Queues

• jobs:queue (BullMQ/Bree)
• jobs:delayed
• jobs:priority
• jobs:repeat
• jobs:progress
• tickets:pending
• tickets:closed
• alerts:pending
• alerts:processed
• emails:pending
• emails:processed
• agents:online
• agents:offline
• dashboard:feed

Example Usage

• Push new ticket: PUBLISH tickets:new {id, text, ...}
• AI worker publishes result: PUBLISH tickets:ai:analysis:{id} {output}
• Backend listens for alerts:ai:analysis:* for auto-ticketing
• Dashboard subscribes to dashboard:events for live updates