From 1625156f5a5e3913f1d2e4c27b66291c31ab4f3a Mon Sep 17 00:00:00 2001 From: jl777 Date: Tue, 13 Mar 2018 16:32:36 +0200 Subject: [PATCH] Fix queueid --- iguana/exchanges/LP_network.c | 23 ++++++++++++++++------- 1 file changed, 16 insertions(+), 7 deletions(-) diff --git a/iguana/exchanges/LP_network.c b/iguana/exchanges/LP_network.c index be3025119..f6ba7fe54 100644 --- a/iguana/exchanges/LP_network.c +++ b/iguana/exchanges/LP_network.c @@ -447,14 +447,23 @@ void LP_commandQ_loop(void *ctx) { if ( ptr->responsesock >= 0 ) { - if ( (result= cJSON_Parse(ptr->msg)) != 0 ) + if ( (argjson= cJSON_Parse(ptr->msg)) != 0 ) { - retjson = cJSON_CreateObject(); - jaddnum(retjson,"queueid",0); - jadd(retjson,"result",result); - retstr = jprint(retjson,1); - if ( (size= nn_send(ptr->responsesock,retstr,(int32_t)strlen(retstr),0)) <= 0 ) - printf("error sending event\n"); + if ( (retstr= LP_command_process(ctx,"127.0.0.1",ptr->responsesock,argjson,(uint8_t *)ptr->msg,ptr->msglen,ptr->stats_JSONonly)) != 0 ) + { + if ( (result= cJSON_Parse(retstr)) != 0 ) + { + free(retstr); + retjson = cJSON_CreateObject(); + jaddnum(retjson,"queueid",ptr->queueid); + jadd(retjson,"result",result); + retstr = jprint(retjson,1); + if ( (size= nn_send(ptr->responsesock,retstr,(int32_t)strlen(retstr),0)) <= 0 ) + printf("error sending event\n"); + } + free(retstr); + } + free_json(argjson); } } }