You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The first thing that comes to the eye is the use on unbuffered channel in:
r.rabbitConnCloseError=make(chan*amqp.Error)
Without knowledge of how to run this code, since there is no main, I can best guess there is a potential dead-lock in any of the unbuffered channels. You could try to initialise the channels as make(chan *amqp.Error, 1) to ensure that the library is not blocked on sending a notification.
This is my complete RabbitMQ code inside rabbitmq package.I use StartConsumer function for Consume message from rabbitmq with goroutine.
go rabbit.StartConsumer("myqueue", "", handler, 1)
After a while my consumer doesn't working and doesn't receive any message.Also I cannot see any error/issue.
The text was updated successfully, but these errors were encountered: