Streaming

Real-time message streaming with windows support for building aggregation pipelines and processing messages as they arrive.

Coming Soon

This page is under construction. For now, see:

• Streaming Examples
• Source Documentation

Quick Example

// Stream messages in real-time
await queen
  .queue('events')
  .stream()
  .subscribe(async (message) => {
    console.log('Real-time:', message.data)
  })

[Full documentation coming soon]