Only start collector if receiving messages
Parse payload if possible prior to push into queue