I have actually opened a thread in the rabbitmq-users list where i checked through wireshark what goes over the wire. It is actually pretty nice to see the flow. I have cross posted since i did not know if it is rabbitmq or my go code... it seems that i get the next message from the wire but the code does not get it at all...
On Tuesday, August 14, 2018 at 10:59:15 PM UTC+3, Justin Israel wrote: > > > > On Wed, Aug 15, 2018, 2:14 AM Sotirios Mantziaris <[email protected] > <javascript:>> 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 [email protected] <javascript:>. >> 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 [email protected]. For more options, visit https://groups.google.com/d/optout.
