Skip to content

Commit b361596

Browse files
committed
Fix examples
Signed-off-by: Charles d'Avernas <[email protected]>
1 parent 099955c commit b361596

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

dsl-reference.md

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -348,7 +348,7 @@ do:
348348
operation: chat-inbox
349349
protocol: http
350350
subscription:
351-
correlation: ${ . == $workflow.input.chat.roomId }
351+
filter: ${ . == $workflow.input.chat.roomId }
352352
consume:
353353
amount: 5
354354
for:
@@ -2046,10 +2046,9 @@ Configures a subscription to an AsyncAPI operation.
20462046

20472047
| Name | Type | Required | Description |
20482048
|:-------|:------:|:----------:|:--------------|
2049-
| correlation | `string` | `no` | A [runtime expression](dsl.md#runtime-expressions), if any, used to filter consumed messages based on their [correlation id.](https://www.asyncapi.com/docs/reference/specification/v3.0.0#correlationIdObject). |
2049+
| filter | `string` | `no` | A [runtime expression](dsl.md#runtime-expressions), if any, used to filter consumed messages. |
20502050
| consume | [`subscriptionLifetime`](#asyncapi-subscription-lifetime) | `yes` | An object used to configure the subscription's lifetime. |
20512051

2052-
20532052
#### Examples
20542053

20552054
```yaml
@@ -2067,7 +2066,7 @@ do:
20672066
operation: chat-inbox
20682067
protocol: http
20692068
subscription:
2070-
correlation: ${ . == $workflow.input.chat.roomId }
2069+
filter: ${ . == $workflow.input.chat.roomId }
20712070
consume:
20722071
amount: 5
20732072
for:
@@ -2103,7 +2102,7 @@ do:
21032102
endpoint: https://fake.com/docs/asyncapi.json
21042103
operation: chat-inbox
21052104
protocol: http
2106-
subscription:
2105+
filter:
21072106
correlation: ${ . == $workflow.input.chat.roomId }
21082107
consume:
21092108
until: ($context.messages | length) == 5

examples/call-asyncapi-publish.yaml

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,8 @@ do:
1010
document:
1111
endpoint: https://fake.com/docs/asyncapi.json
1212
operation: findPetsByStatus
13-
server: staging
13+
server:
14+
name: staging
1415
message:
1516
payload:
1617
petId: ${ .pet.id }

examples/call-asyncapi-subscribe-consume-until.yaml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@ do:
99
with:
1010
document:
1111
endpoint: https://fake.com/docs/asyncapi.json
12-
operation: getNotifications
1312
channel: /notifications
1413
subscription:
1514
filter: '${ .correlationId == $context.userId and .payload.from.firstName == $context.contact.firstName and .payload.from.lastName == $context.contact.lastName }'

0 commit comments

Comments
 (0)