change pubsub to queue