1 files changed, 3 insertions, 0 deletions
diff --git a/queue.h b/queue.h
index e68467b9..c7e2db21 100644
--- a/queue.h
+++ b/queue.h
@@ -165,6 +165,9 @@ typedef struct queue_s {
 #define QUEUE_MODE_ENQDEQ 0
 #define QUEUE_MODE_ENQONLY 1
 
+#define QUEUE_IDX_DA_WORKER 0 /* index for the DA worker (fixed) */
+#define QUEUE_PTR_DA_WORKER(x) (&((pThis)->pWrkThrds[0]))
+
 /* the define below is an "eternal" timeout for the timeout settings which require a value.
  * It is one day, which is not really eternal, but comes close to it if we think about
  * rsyslog (e.g.: do you want to wait on shutdown for more than a day? ;))