@@ -3296,6 +3296,13 @@ qqueueCorrectParams(qqueue_t *pThis)
32963296 if (pThis -> iHighWtrMrk == 0 ) { /* guard against very low max queue sizes! */
32973297 pThis -> iHighWtrMrk = pThis -> iMaxQueueSize ;
32983298 }
3299+ LogMsg (0 , RS_RET_CONF_PARSE_WARNING , LOG_WARNING ,
3300+ "queue \"%s\": queue.highWaterMark "
3301+ "is set below queue size. It has been automatically been "
3302+ "adjusted to %d. In any case, we strongly recommend to review the "
3303+ "queue definition and resolve inconsistencies to guarantee "
3304+ "the config really matches your intent." ,
3305+ obj .GetName ((obj_t * ) pThis ), pThis -> iHighWtrMrk );
32993306 }
33003307 if ( pThis -> iLowWtrMrk < 2
33013308 || pThis -> iLowWtrMrk > pThis -> iMaxQueueSize
@@ -3304,6 +3311,13 @@ qqueueCorrectParams(qqueue_t *pThis)
33043311 if (pThis -> iLowWtrMrk == 0 ) {
33053312 pThis -> iLowWtrMrk = 1 ;
33063313 }
3314+ LogMsg (0 , RS_RET_CONF_PARSE_WARNING , LOG_WARNING ,
3315+ "queue \"%s\": queue.lowWaterMark "
3316+ "is set below queue size or highWaterMark. It has been automatically been "
3317+ "adjusted to %d. In any case, we strongly recommend to review the "
3318+ "queue definition and resolve inconsistencies to guarantee "
3319+ "the config really matches your intent." ,
3320+ obj .GetName ((obj_t * ) pThis ), pThis -> iHighWtrMrk );
33073321 }
33083322
33093323 if ((pThis -> iMinMsgsPerWrkr < 1
0 commit comments