Neat idea! Would it help if subscriber states were also stored? (read position, queue name, filters, etc) Then instead of waking all subscription threads to do

Neat idea! Would it help if subscriber states were also stored? (read position, queue name, filters, etc) Then instead of waking all subscription threads to do their own N=1 SELECT when stat(2) changes, the polling thread could do Events INNER JOIN Subscribers and only wake the subscribers that match.