pubsub: make sure to catch up sub in a transaction (#229)

pubsub: make sure to catch up sub in a transaction (#229) #144