Skip to content

[queue] Pluggable queue drivers (memory / unstorage / qstash / sqs) #50

Description

@productdevbook

Part of #24.

```ts
import { createEmail } from 'unemail'
import memoryQueue from 'unemail/queue/memory'
import qstashQueue from 'unemail/queue/qstash'

const email = createEmail({
driver: resend(...),
queue: memoryQueue({ concurrency: 5 }),
// or: queue: qstashQueue({ token, url })
})

await email.enqueue({ to, subject, react: , scheduledAt: '3d' })
```

  • Queue interface: `enqueue`, `process`, `fail`, `retry`
  • In-memory + unstorage adapter (persists to any unstorage driver)
  • QStash adapter (serverless-friendly)
  • SQS adapter

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or improvementv1.0v1.0 rewrite (shipped)

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions