Commit 1c03ee73 authored by Geoff Simmons's avatar Geoff Simmons

Send fails (and worker thread exits) if a send immediately after a

successful reconnect fails.
parent d633a76d
......@@ -147,6 +147,7 @@ wrk_send(void **amq_worker, dataentry *entry, worker_data_t *wrk)
err = MQ_Send(*amq_worker, entry->data, entry->end);
if (err != NULL) {
wrk->fails++;
*amq_worker = NULL;
LOG_Log(LOG_ALERT,
"Worker %d: Failed to send data after reconnect: %s",
wrk->id, err);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment