-
Notifications
You must be signed in to change notification settings - Fork 68
/
amqp_msg_sender.yaml
33 lines (28 loc) · 975 Bytes
/
amqp_msg_sender.yaml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
bindings:
mytext_val: AlphaNumericString(100)
myroutingkey: CSVFrequencySampler('csv/routing_keys.csv', 'name')
# Doc-level parameters (must be static)
params:
# whether to do publisher confirm (for reliable publishing)
# - default: false
publisher_confirm: true
#publisher_confirm: true
# If 'publisher_confirm' is true, use one of the following 3 confirm modes:
# - individual (wait_for_confirm individually)
# - batch (wait_for_confirm in batch)
# - async [default]
#confirm_mode: async
#confirm_mode: individual
confirm_mode: batch
# Only relevant when 'publisher_confirm' is true and 'confirm_mode' is "batch"
confirm_batch_num: 10
# default timeout value (in milliseconds)
# - only relevant when publisher_confirm' is true and 'confirm_mode' is NOT "async"
dft_confirm_timeout_ms: 1000
blocks:
msg_send_block:
ops:
op1:
AmqpMsgSender: ""
routing_key: "{myroutingkey}"
message: "{mytext_val}"