syslog-ng source
mqtt-worker.c File Reference
#include "mqtt-worker.h"
#include "mqtt-destination.h"
#include "thread-utils.h"
#include "apphook.h"
#include "messages.h"
#include "timeutils/misc.h"
#include <stdio.h>
Include dependency graph for mqtt-worker.c:

Macros

#define PUBLISH_TIMEOUT   10000L
 
#define YIELD_INTERVAL_MSEC   500
 

Functions

LogThreadedDestWorker * mqtt_dw_new (LogThreadedDestDriver *o, gint worker_index)
 

Macro Definition Documentation

◆ PUBLISH_TIMEOUT

#define PUBLISH_TIMEOUT   10000L

◆ YIELD_INTERVAL_MSEC

#define YIELD_INTERVAL_MSEC   500

Function Documentation

◆ mqtt_dw_new()

LogThreadedDestWorker* mqtt_dw_new ( LogThreadedDestDriver *  o,
gint  worker_index 
)