update code to match redispubsub