queue: pubsub implementation for redis queue