WIP: decouple propagation of streamer events through a queue

This doesn't work yet.

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.