diff --git a/mbuni/extras/pgsql-queue/mms_pgsql_queue.c b/mbuni/extras/pgsql-queue/mms_pgsql_queue.c index 1612838..7b2cbbd 100644 --- a/mbuni/extras/pgsql-queue/mms_pgsql_queue.c +++ b/mbuni/extras/pgsql-queue/mms_pgsql_queue.c @@ -1151,8 +1151,12 @@ static void pgq_queue_run(char *dir, if (*rstop) break; gwthread_sleep(sleepsecs); - if (gwlist_len(items_list) > MAX_QLEN * num_threads) + if (gwlist_len(items_list) > MAX_QLEN * num_threads) { + mms_warning(0, "pgsql_queue", NULL, + "Queue [%s] large [%d entries]. Will wait a little to see if it clears", + dir, (int)gwlist_len(items_list)); goto l1; /* don't allow too many pending requests in the waiting queue. */ + } } while (1); mms_info(0, "pgsql_queue", NULL, "Queue runner on [%s] shutdown, started...", dir);