refine Subscriber
update the Subscriber implementations in the queryrepo module