hi,

i have setup a "consumer" for a rabbitmq queue. Every delivery is put in a 
channel which is picked up by a goroutine.
After processing the delivery is then Ack or Nack based on the success of 
the processing.
It seems that the first one is processed ok but the rest cannot be Ack/Nack.
The ui of rabbitmq shows every message in a unacked state, which probably 
means that the consumer gets the message from the queue but something 
prevents it for being put in the above mentioned channel.

The consume part of the queue can be found here 
: https://github.com/mantzas/patron/blob/amqp-lock/async/amqp/amqp.go
The processing goroutine can be found 
here: https://github.com/mantzas/patron/blob/amqp-lock/async/component.go

Does anybody have a idea?

-- 
You received this message because you are subscribed to the Google Groups 
"golang-nuts" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to golang-nuts+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

Reply via email to