Concurrency stuff

Added message queue to notifiers, added ability to notify
IMessageQueueSource sources every x messages received in queue, and
fixed some concurrency issues.

Also may have introduced lag. not sure yet.