prototype of pub-sub queue