EnQHandler.Rcv

queue.go

func (h EnQHandler) Rcv(msg beehive.Msg, ctx beehive.RcvContext) error {
	enq := msg.Data().(Enque)

	dict := ctx.Dict(active)
	key := string(enq.Task.Queue)

	var tasks TaskRing
	if val, err := dict.Get(key); err == nil {
		tasks = val.(TaskRing)
	}

	enq.Task.ID = tasks.Stats.Enque + 1
	tasks.Enque(enq.Task)

	return dict.Put(key, tasks)
}