* Modify message processing to allow observation of websocket queue being drained. * Extend MessageProcessing to allow observation of REST message fetching and "all message fetching and processing".