Collect messages over TCP, ID them, and queue them for processing.