WIP streamer: decouple propagation of events through a queue

In principle this is the first step to propagating the "realtime
annotation" events through an external queue. More error-checking will
almost certainly be required, and sending the entire annotation through
the queue seems absurd... so WIP it is.