5 Consume until reception of json message.
7 Arguments: json[, auto_offset_reset, timeout, background, debug]
8 * json: json file that we want to wait for ('any' to skip matching).
9 * timeout: timeout for the operation in seconds.
10 * auto_offset_reset: auto offset reset (earliest, latest, etc.). By default: latest.
11 * background: "yes"|["no"]. Executes the step in background. By default is blocking, allowing to gather the result code for the step.
12 * debug: "yes"|["no"]. Python kafka library debug information.
16 - action: SMPC/consume_json
20 auto_offset_reset: earliest
25 Produces a json message to the kafka message bus.
27 Arguments: json[, delay_ms, background, debug]
28 * json: json file that we want to produce.
29 * delay_ms: delay before producing in milliseconds.
30 * background: "yes"|["no"]. Executes the step in background. By default is blocking, allowing to gather the result code for the step.
31 * debug: "yes"|["no"]. Python kafka library debug information.
35 - action: SMPC/produce_json:
42 Administration actions.
44 Arguments: operation[, debug]
45 * operation: only 'clean_topic' implemented
46 * debug: "yes"|["no"]. Python kafka library debug information.
48 clean_topic: administration operation to clear message bus in case you want to consume reading earliest messages in the queue. By default, consumer offsets to latest message, but it won't see nothing if it is launched after production of the expected message. Depending on the way you define the test case, you will need clean or not the message bus.
50 * Example(1): given an 'SMPC' kafka node:
55 operation: clean_topic
57 - action: AF/send_xml_to_entity
61 - action: SPMC/consume_json
64 auto_offset_reset: earliest
67 * Example(2): given an 'SMPC' kafka node:
70 - action: SPMC/consume_json
75 - action: AF/send_xml_to_entity
80 * Example(3): given an 'SMPC' kafka node:
83 - action: SPMC/produce_json
89 - action: AF/wait_xml_from_entity