From: DR695H <dr695h@att.com>
Date: Thu, 13 Jun 2019 21:24:01 +0000 (-0400)
Subject: forgot to add hvess changes to the socket change
X-Git-Tag: 1.5.0~53
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F40%2F89840%2F1;p=testsuite.git

forgot to add hvess changes to the socket change

Change-Id: Id83727ba0a06f28ae0b7bf41c074542b3801e3f8
Issue-ID: TEST-158
Signed-off-by: DR695H <dr695h@att.com>
---

diff --git a/robot/resources/dcae/hvves.robot b/robot/resources/dcae/hvves.robot
index 123bacb3..b7bfb232 100644
--- a/robot/resources/dcae/hvves.robot
+++ b/robot/resources/dcae/hvves.robot
@@ -4,8 +4,9 @@ Library     OperatingSystem
 Library     RequestsLibrary
 Library     BuiltIn
 Library     Collections
-Library     SocketUtils
+Library     ONAPLibrary.Utilities    
 Library    String
+Library    ONAPLibrary.Kafka
 Resource    ../mr_interface.robot
 
 *** Variables ***
@@ -40,7 +41,10 @@ Start HV-VES TCP Client And Send Message
 Decode Last Message From Topic
     [Documentation]     Decode last message from Kafka topic.
     [Arguments]     ${kafka_server}     ${kafka_port}     ${kafka_topic}    ${sec_protocol}    ${mechanisms}    ${username}    ${password}
-    #Catenate    http://message-router.onap:3904/events/${kafka_topic}/group1/C1?timeout=5000?limit=1
+    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
     [Return]    ${msg}