Simple Queue Subscriber

qsub.go

// All subscriptions with the same queue name will form a queue
// group at runtime. Each message will be delivered to only one
// subscriber per queue group. You can have as many queue groups
// as you wish, and as many members in a single group as you like.
// Normal subscribers will continue to work as expected.

nc.QueueSubscribe("foo", "job_workers", func(m *Msg) {
  // Do some work, then send reply.
  nc.Publish(m.ReplyTo, myAnswer)
})