Redis transport.
Set of queues being consumed from (excluding fanout queues).
Client used to publish messages, BRPOP etc.
Pub/Sub connection used to consume fanout queues.
Handle AIO event for one of our file descriptors.
Called when hub starts.
Called by hub before each poll()
Set of queues being consumed from (excluding fanout queues).
Client used to publish messages, BRPOP etc.
Pub/Sub connection used to consume fanout queues.