Created and maintain running flag in collector class.  Also, parsed msg_type and msg_from out of piped messages.
Created sleep counter to allow checking for messages once a second regardless of duration of that processes sleep time between doing something.