Minor changes

This commit is contained in:
Loic Guegan 2023-07-15 22:24:23 +02:00
parent 9f4eb5b6b8
commit d2c44f9a57

View file

@ -96,12 +96,12 @@ void publish(void *publisher, char *filepath, char* client, long int interval){
strcat(buffer,line); strcat(buffer,line);
msglen+=read; msglen+=read;
} else { } else {
zmq_send (publisher, buffer, ZMQ_MSG_SIZE, 0); zmq_send (publisher, buffer, msglen, 0);
sprintf(buffer,"%s\n%s\n%s\n%ld\n",ZMQ_TOKEN,__key,client,interval); sprintf(buffer,"%s\n%s\n%s\n%ld\n",ZMQ_TOKEN,__key,client,interval);
strcat(buffer,line); strcat(buffer,line);
msglen=strlen(buffer); msglen=strlen(buffer);
} }
} }
fclose(fptr); fclose(fptr);
zmq_send (publisher, buffer, ZMQ_MSG_SIZE, 0); zmq_send (publisher, buffer, msglen, 0);
} }