amirho/docs.nestjs.com
1
0
Fork 0
mirror of https://github.com/nestjs/docs.nestjs.com.git synced 2026-02-25 22:15:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3383 from suuuuuuminnnnnn/docs/mqtt-per-pattern-qos

Browse Source 
docs(microservices): document mqtt pattern qos
This commit is contained in:
Kamil Mysliwiec
2026-02-04 11:46:54 +01:00
committed by GitHub
parent 326e89ec97 700be668e3
commit a9a302ec9a
1 changed files with 30 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
content/microservices/mqtt.md
View File

@@ -143,7 +143,36 @@ const app = await NestFactory.createMicroservice(AppModule, {
});
```
If a topic specific QoS is required, consider creating a [Custom transporter](https://docs.nestjs.com/microservices/custom-transport).
#### Per-pattern QoS
You can override the MQTT subscription QoS on a per-pattern basis by providing `qos` in the `extras` field of the pattern decorator. When not specified, the global `subscribeOptions.qos` is used as the default.
```typescript
@@filename()
@EventPattern('critical-events', { extras: { qos: 2 } })
handleCriticalEvent(@Payload() data: any) {
// This subscription uses QoS 2
}
@EventPattern('metrics', { extras: { qos: 0 } })
handleMetrics(@Payload() data: any) {
// This subscription uses QoS 0
}
@@switch
@Bind(Payload())
@EventPattern('critical-events', { extras: { qos: 2 } })
handleCriticalEvent(data) {
// This subscription uses QoS 2
}
@Bind(Payload())
@EventPattern('metrics', { extras: { qos: 0 } })
handleMetrics(data) {
// This subscription uses QoS 0
}
```
> info **Hint** Per-pattern QoS configuration does not affect existing behavior. When `extras.qos` is not specified, the subscription uses the global `subscribeOptions.qos` value.
#### Record builders