ESL_DECLARE(esl_status_t) esl_sendmsg(esl_handle_t *handle, esl_event_t *event, const char *uuid)
{
- char cmd_buf[128] = "sendmsg";
+ char cmd_buf[128] = "sendmsg\n";
char send_buf[1292] = "";
char *txt;
}
if (uuid) {
- snprintf(cmd_buf, sizeof(cmd_buf), "sendmsg %s", uuid);
+ snprintf(cmd_buf, sizeof(cmd_buf), "sendmsg %s\n", uuid);
}
esl_event_serialize(event, &txt, ESL_FALSE);
- esl_log(ESL_LOG_DEBUG, "SENDMSG\n%s\n", txt);
+ esl_log(ESL_LOG_DEBUG, "%s%s\n", cmd_buf, txt);
+ if (send(handle->sock, cmd_buf, strlen(cmd_buf), 0) <= 0) goto fail;
if (send(handle->sock, txt, strlen(txt), 0) <= 0) goto fail;
free(txt);
if (encode) {
esl_url_encode(hp->value, encode_buf, encode_len);
} else {
- esl_snprintf(encode_buf, encode_len, "[%s]", hp->value);
+ esl_snprintf(encode_buf, encode_len, "%s", hp->value);
}