amqp

amqp copied to clipboard

Hi, I've encountered an issue when trying to use AMQPLAIN authentication. It seems that the current implementation does not work out of the box. I looked for an official reference...

hodbn

Use atomic operation to prevent deadlock when publishing in confirm mode

2

When producer push message and confirm message in one goroutine, deadlock would occur. In [confirms.go](https://github.com/streadway/amqp/blob/master/confirms.go), Publish method might wait lock infinitely that One method held once confirm channel blocked. So...

RainJoe

No message received on Flow channel

1

Hi, thanks for your great work on AMQP implementation! I having a problem on detect when channel enter in flow mode using RabbitMQ 3.8.15, after the channel creation i start...

Bedotech

Is this project dead ?

3

There hasn't been any activity since last year . Is this project no longer maintained ? @streadway

parthibd

fix #254 Channel.Publish blocks indefinitely

3

I encountered a bug similar to this comment: https://github.com/streadway/amqp/issues/254#issuecomment-316401642 However, in a weak network environment, I get a deadlock after N+1 messages have been sent where N is the size...

sljeff

"error":"bad_request","reason":"payload_not_string"} this is my test JSON { "properties": { "content_type": "application/json"}, "routing_key": "info", "payload_encoding": "string", "payload": { "records":{ "name":"testname"}}}

jayber01

Support PublishWithContext

1

Relates to #266 and #464. The method adds the support of cancelling blocking operations in the Publish method. The PR replaces mutex with semaphore. The changes are not breaking. All...

hedhyw

channel.go: avoid race condition by synchronizing ch.send calls

1

- for example calls to `Publish` and `QueueDeclare` from multiple goroutines lead to messed up frames and eventual connection failure - i tested it by running 25 goroutines with infinite...

xaka

(Continued) Added support for cert-only login without user and password

1

I tried to finish the work inside the #121 as best I could seeing the recommendation here https://github.com/streadway/amqp/issues/355#issuecomment-540677849 Here is the summary of my work * Made the changes requested...

ugurcan377

Channel shutdown process improvements: shutdown error added as an own…

1

**Problem:** Ambiguous behavior on Channel shutdown. If you consume using a Channel you cannot get the shutdown cause even if you use NotifyClose chan listener. Delivery chan could be selected...

askretov