NSQ
Distributed realtime messaging platform with in-memory topics and channels that spill to disk.
- Provider
- default
- Kind
- Queue
- Category
- Messaging
- Official docs
- https://nsq.io/components/nsqd.html
| property | type | values | required | kind default | this component |
|---|---|---|---|---|---|
| backoff | enum | none | fixed | exponential | exponential-jitter | no | — | inherited |
| deadLetterQueue | boolean | — | no | false | ▸ false |
| delivery | enum | at-most-once | at-least-once | exactly-once | yes | — | ▸ at-least-once |
| instances | integer | — | no | — | inherited |
| managed | boolean | — | no | false | ▸ false |
| maxAttempts | integer | — | no | — | inherited |
| memQueueSize | integer | — | no | 10000 | inherited |
| messageTimeoutSeconds | integer | — | no | 60 | inherited |
| ordering | enum | none | per-key | global | no | none | ▸ none |
| persistence | boolean | — | no | true | ▸ false |
| replay | boolean | — | no | false | ▸ false |
| retentionDays | integer | — | no | — | inherited |
| role | enum | work | dlq | retry | offline-mailbox | frontier | no | work | inherited |
| tlsRequired | boolean | — | no | false | inherited |
Every rule whose selector covers this component's kind or its category. Whether a rule fires depends on the design: its properties, its edges and its groups.
A queue that receives asynchronous traffic and has no dead-letter queue either drops poison messages or retries them forever. Neither outcome leaves anything for a human to investigate.
- — all of these hold:
- — the node's `deadLetterQueue` is false
- — the node has at least one asynchronous incoming edge
A retry queue is where poison messages end up. With no dead-letter queue they are retried forever or dropped in silence, and nobody ever looks at the failed payment.
- — all of these hold:
- — the node's `role` is "retry"
- — the node's `deadLetterQueue` is false
Retrying a transient failure at full speed turns one slow dependency into a retry storm. A retry queue backs off, preferably exponentially and with jitter.
- — all of these hold:
- — the node's `role` is "retry"
- — any of these hold:
- — the node's `backoff` has no value
- — the node's `backoff` is "none"
nodes:
- { id: "nsq", component: "nsq" }# yaml-language-server: $schema=../../schema/component.schema.json # NSQ: distributed topic/channel broker. Guarantees at-least-once delivery, keeps 10000 messages per # channel in memory before spilling to disk and does not require TLS ("Design", "nsqd"). schemaVersion: "1" type: "component" id: "nsq" kind: "queue" provider: "default" docs: "https://nsq.io/components/nsqd.html" defaults: delivery: "at-least-once" ordering: "none" persistence: false deadLetterQueue: false replay: false managed: false properties: memQueueSize: type: "integer" default: 10000 messageTimeoutSeconds: type: "integer" default: 60 tlsRequired: type: "boolean" default: false