changed queue object Construction/Startup interface

1 files changed, 5 insertions, 1 deletions

diff --git a/syslogd.c b/syslogd.c
index 13ff8960..abb6d16b 100644
--- a/syslogd.c
+++ b/syslogd.c
@@ -2268,7 +2268,6 @@ static int parseLegacySyslogMsg(msg_t *pMsg, int flags)
 void
 logmsg(int pri, msg_t *pMsg, int flags)
 {
-	DEFiRet;
 	char *msg;
 	char PRItext[20];
 
@@ -3356,6 +3355,11 @@ init(void)
 		fprintf(stderr, "fatal error %d: could not create message queue - rsyslogd can not run!\n", iRet);
 		exit(1);
 	}
+	CHKiRet_Hdlr(queueStart(pMsgQueue)) {
+		/* no queue is fatal, we need to give up in that case... */
+		fprintf(stderr, "fatal error %d: could not start message queue - rsyslogd can not run!\n", iRet);
+		exit(1);
+	}
 
 	Initialized = 1;