On Wed, Aug 15, 2018, 2:14 AM Sotirios Mantziaris <smantzia...@gmail.com> wrote:
> 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? > I have an application with a similar pattern where is manually acks each message after the processing succeeds. So I can check your logic against mine. In the meantime, can you clarify if you confirmed that processing always happens locally and the ack does get called every time, but you are just not seeing it deliver the ack to Rabbitmq? > -- > 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. > -- 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.
