Btw, I've tried it with latest master - I have following:

BEGINcommitTransaction
   CODESTARTcommitTransaction
   dbgprintf("omsgkafka: committransaction called\n");
   srSleep(1500, 0);

.....

Then I send 3 log lines and restart rsyslog 3 times in a row (while
commitTransaction is still sleeping). After 3rd restart queue file
disappears from disk.

7225.277613984:main thread    : destructing ruleset 0x1e3a150, name 0x1e3a190
7225.277621027:main thread    : kafka_action queue: initiating worker
thread shutdown sequence
7225.277627291:main thread    : kafka_action queue: trying shutdown of
regular workers
7225.277633642:main thread    : kafka_action queue: regular queue
workers shut down.
7225.277639649:main thread    : kafka_action queue: checking to see if
we need to cancel any worker threads of the primary queue
7225.277646122:main thread    : kafka_action queue: worker threads
terminated, remaining queue size log 0, phys 0.
7225.277653082:main thread    : kafka_action queue: persisting queue
to disk, 0 entries...
7225.277662432:main thread    : strm 0x1e462d0: file
-1(prism_kafka_queue) closing
7225.277668895:main thread    : strm 0x1e462d0: file
-1(prism_kafka_queue) flush, buflen 0 (no need to flush)
7225.277676550:main thread    : strm 0x1e46570: file
-1(prism_kafka_queue) closing
7225.277683976:main thread    : strm 0x1e46810: file
-1(prism_kafka_queue) closing
7225.277691272:main thread    : strmCloseFile: deleting
'/var/spool/rsyslog/prism_kafka_queue.00000001'
_______________________________________________
rsyslog mailing list
http://lists.adiscon.net/mailman/listinfo/rsyslog
http://www.rsyslog.com/professional-services/
What's up with rsyslog? Follow https://twitter.com/rgerhards
NOTE WELL: This is a PUBLIC mailing list, posts are ARCHIVED by a myriad of 
sites beyond our control. PLEASE UNSUBSCRIBE and DO NOT POST if you DON'T LIKE 
THAT.

Reply via email to