Sets up a TCP connection to NSQD. Both consumers and producers use this

Both consumers and producers use Connection, which, at a lower level, kicks off message processing and issues commands to NSQD. This module handles some of the trickier command queueing, flushing, etc

A consumer or producer will initialize this supervisor empty to start. Candidate nsqd connections will be discovered elsewhere and added with start_child

A consumer is a process that creates connections to NSQD to receive messages for a specific topic and channel. It has three primary functions

When messages fail unexpectedly hard, we go into “backoff mode”

Functions for connecting, disconnecting, managing connections, etc

Consumers have a lot of logic around calculating and distributing RDY. This is where that goes!

A producer is a process that connects to one or many NSQDs and publishes messages