On Wed, Aug 15, 2018 at 8:05 AM Sotirios Mantziaris <smantzia...@gmail.com> wrote:
> 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... > If I am reading that properly, you are saying that your message handler is not actually getting triggered at all for subsequent messages? That would mean you have some kind of blocking problem in your goroutines and channels. I thought initially you were saying that you verified the handler was constantly receiving messages and calling ack() but the ack never makes it back to Rabbitmq > 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 <smant...@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...@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. > -- 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.
