# Verify that pg_notification_queue_usage correctly reports a non-zero result,
# after submitting notifications while another connection is listening for
# those notifications and waiting inside an active transaction.

session "listener"
step "listen"	{ LISTEN a; }
step "begin"	{ BEGIN; }
teardown		{ ROLLBACK; UNLISTEN *; }

session "notifier"
step "check"	{ SELECT pg_notification_queue_usage() > 0 AS nonzero; }
step "notify"	{ SELECT count(pg_notify('a', s::text)) FROM generate_series(1, 1000) s; }

permutation "listen" "begin" "check" "notify" "check"