amqp

amqp copied to clipboard

I have a publisher that uses JMS to publish data to a topic via AMQP. It uses a message broker called WSO2 message broker. In the default java implementation a...

HeshanSudarshana

The consumer can not create a connection after the main node of the RabbitMQ restart. SpringBoot has conf to solve this issue by setting `missing-queues-fatal: false`. Connection issue occurs just...

akhammadli

channel.Consume with a empty queue name

1

I created two queues with two different queue names and keys in the same channel. I use the Consume function like this: `delivery, err := consumer.channel.Consume("", "", true, false, false,...

cuizhipeng326

connection pool problem

2

I can not found document that support connection pool. In the web, connection pool is necessary that avoid connect and reconnect ..

l1905

Unable to use channel.Notify* if the same channel is used

1

Hi, Using same channel for publishing messages prevents us from using `channel.NotifyPublish`, `channel.NotifyReturn` and `channel.NotifyConfirm` methods. As soon as the **first a few** messages are delivered, we can not receive...

bentcoder

I have encountered the problem using example that exports Session object. Connection sends close notification before channels shutdown. Client must continue to check for channel notifications before trying to reconnect....

franissirkovic

Connection.Close intermittently hangs when connection.NotifyClose channels are not consumed

6

While debugging an intermittent hang when calling Connection.Close() I discovered the following: When it hangs I can see it waiting on channel send at this line: https://github.com/streadway/amqp/blob/70e15c650864f4fc47f5d3c82ea117285480895d/connection.go#L390 Interestingly, to reach...

nvx

Is this project still maintained?

7

It seems the activity on this repo, and especially on open issues has progressively waned in 2019 and 2020. The most conspicuous outstanding issue (IMHO) is #412, plus some other...

vibridi

Request Updating library (go.mod) to v1.14

3

Please and thank you.

houseofcat

same channel hadler in many go routiens

1

I am having single channel handler to publish message and this handler is passed to multiple go routine at same time. Are channel handlers thread safe?

rkr-rakesh