ApsaraMQ for RocketMQ
Distributed message queue for asynchronous communication, with ordered, transactional and scheduled messages.
- Provider
- alibabacloud
- Kind
- Queue
- Category
- Messaging
| property | type | values | required | kind default | this component |
|---|---|---|---|---|---|
| backoff | enum | none | fixed | exponential | exponential-jitter | no | — | inherited |
| deadLetterQueue | boolean | — | no | false | inherited |
| delivery | enum | at-most-once | at-least-once | exactly-once | yes | — | ▸ at-least-once |
| instanceVersion | enum | 4.x | 5.x | no | — | inherited |
| instances | integer | — | no | — | inherited |
| managed | boolean | — | no | false | ▸ true |
| maxAttempts | integer | — | no | — | inherited |
| messageType | enum | normal | ordered | transactional | scheduled | no | normal | inherited |
| ordering | enum | none | per-key | global | no | none | inherited |
| persistence | boolean | — | no | true | ▸ true |
| replay | boolean | — | no | false | ▸ true |
| retentionDays | integer | — | no | — | inherited |
| role | enum | work | dlq | retry | offline-mailbox | frontier | no | work | 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: "rocketmq", component: "alibaba-rocketmq" }# yaml-language-server: $schema=../../schema/component.schema.json # ApsaraMQ for RocketMQ: "a distributed message queue service that supports reliable message-based # asynchronous communication among microservices, distributed systems, and serverless applications" # ("Introduction to ApsaraMQ for RocketMQ"). Messages are persisted and redelivered until consumed, # with ordered, transactional and scheduled messages as message types. schemaVersion: "1" type: "component" id: "alibaba-rocketmq" kind: "queue" provider: "alibabacloud" docs: "https://www.alibabacloud.com/help/en/apsaramq-for-rocketmq" defaults: managed: true delivery: "at-least-once" persistence: true replay: true properties: instanceVersion: type: "enum" values: ["4.x", "5.x"] messageType: type: "enum" values: ["normal", "ordered", "transactional", "scheduled"] default: "normal"