code: func (q *Queue) WatchContext(ctx context.Context) (eventq chan events.Event) {
  	return q.CallbackWatchContext(ctx, nil)
  }
docs: // WatchContext returns a channel where all items published to the queue will
  // be received. The channel will be closed when the provided context is
  // cancelled.