typo
This commit is contained in:
@@ -279,7 +279,7 @@ function identifyUserIntention(a::agent, usermsg::String)
|
||||
# send prompt
|
||||
CommUtils.request(a.mqttClient, msg, pubtopic=a.mqttClient.pubtopic.llmAI)
|
||||
starttime = Dates.now()
|
||||
timeout = 10
|
||||
timeout = 30
|
||||
result = nothing
|
||||
|
||||
while true
|
||||
@@ -287,7 +287,7 @@ function identifyUserIntention(a::agent, usermsg::String)
|
||||
CommUtils.mqttRun(a.mqttClient, payloadChannel)#BUG no msg received
|
||||
if isready(payloadChannel)
|
||||
topic, payload = take!(payloadChannel)
|
||||
if payload[:msgMeta][:repondToMsgId] == msgPrompt[:msgMeta][:msgId]
|
||||
if payload[:msgMeta][:repondToMsgId] == msg[:msgMeta][:msgId]
|
||||
result = payload[:txt]
|
||||
break
|
||||
end
|
||||
|
||||
Reference in New Issue
Block a user