diff options
Diffstat (limited to 'robot/resources/dcae')
| -rw-r--r-- | robot/resources/dcae/hvves.robot | 16 |
1 files changed, 5 insertions, 11 deletions
diff --git a/robot/resources/dcae/hvves.robot b/robot/resources/dcae/hvves.robot index b7bfb232..07288a6e 100644 --- a/robot/resources/dcae/hvves.robot +++ b/robot/resources/dcae/hvves.robot @@ -10,10 +10,7 @@ Library ONAPLibrary.Kafka Resource ../mr_interface.robot *** Variables *** -${hvves_message} \xaa\x01\x00\x00\x00\x00\x00\x01\x00\x00\x01'\n\x94\x02\n\x0esample-version\x12\x08perf3gpp\x18\x01 \x01*\nperf3GPP222\x11sample-event-name:\x11sample-event-type@\xf1\x9a\xfd\xdd\x05H\xf1\x9a\xfd\xdd\x05R\x15sample-nf-naming-codeZ\x16sample-nfc-naming-codeb\x15sample-nf-vendor-namej\x1asample-reporting-entity-idr\x1csample-reporting-entity-namez\x10sample-source-id\x82\x01\x0fsample-xnf-name\x8a\x01\tUTC+02:00\x92\x01\x057.0.2\x12\x0etest test test -${hvves_kafka_topic} HV_VES_PERF3GPP -${security_protocol} SASL_PLAINTEXT -${sasl_mechanisms} PLAIN +${HVVES_MESSAGE} \xaa\x01\x00\x00\x00\x00\x00\x01\x00\x00\x01'\n\x94\x02\n\x0esample-version\x12\x08perf3gpp\x18\x01 \x01*\nperf3GPP222\x11sample-event-name:\x11sample-event-type@\xf1\x9a\xfd\xdd\x05H\xf1\x9a\xfd\xdd\x05R\x15sample-nf-naming-codeZ\x16sample-nfc-naming-codeb\x15sample-nf-vendor-namej\x1asample-reporting-entity-idr\x1csample-reporting-entity-namez\x10sample-source-id\x82\x01\x0fsample-xnf-name\x8a\x01\tUTC+02:00\x92\x01\x057.0.2\x12\x0etest test test *** Keywords *** Check Message Router Api @@ -35,16 +32,13 @@ Check If Topic Exists Start HV-VES TCP Client And Send Message [Documentation] Starts HV-VES TCP client sends message to the collector. [Arguments] ${hvves_server_ip} ${hvves_server_port} - ${msg}= Convert To Bytes ${hvves_message} + ${msg}= Convert To Bytes ${${HVVES_MESSAGE}} Send Binary Data ${hvves_server_ip} ${hvves_server_port} ${msg} Decode Last Message From Topic [Documentation] Decode last message from Kafka topic. - [Arguments] ${kafka_server} ${kafka_port} ${kafka_topic} ${sec_protocol} ${mechanisms} ${username} ${password} - Connect kakfa ${kafka_server}:${kafka_port} - Consume kakfa ${kafka_topic} - # TODO need to support sasl - #${msg}= Run kafkacat -X security.protocol=${sec_protocol} -X sasl.mechanisms=${mechanisms} -X sasl.username=${username} -X sasl.password=${password} -D "" -o -1 -c 1 - ${msg}= Run kafkacat -C -b ${kafka_server}:${kafka_port} -t ${kafka_topic} -X security.protocol=${sec_protocol} -X sasl.mechanisms=${mechanisms} -X sasl.username=${username} -X sasl.password=${password} -D "" -o -1 -c 1 + [Arguments] ${kafka_server} ${kafka_port} ${kafka_topic} ${username} ${password} + Connect kakfa ${kafka_server}:${kafka_port} ${username} ${password} + ${msg}= Consume kakfa ${kafka_topic} [Return] ${msg} |