code: func (q *Queue) Watch() (eventq chan events.Event, cancel func()) {
  	return q.CallbackWatch(nil)
  }
docs: // Watch returns a channel which will receive all items published to the
  // queue from this point, until cancel is called.