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
	)