amqp
amqp copied to clipboard
streadway
Go client for AMQP 0.9.1
File: https://github.com/streadway/amqp/blob/master/read.go Details: 1. The condition is redundant In github.com/streadway/amqp.readFloat32(io.Reader): The same code is executed regardless of the condition ([CWE-398](http://cwe.mitre.org/data/definitions/398.html)) 2. The condition is redundant In github.com/streadway/amqp.readFloat64(io.Reader): The same code...
About that: https://github.com/streadway/amqp/blob/e6b33f460591b0acb2f13b04ef9cf493720ffe17/consumers.go#L72 I suppose the buffering was added there to consume the server flow as fast as possible. But if the consumer is slow and `autoAck` is true, it...
fixed grammatical error and typo in : `_examples/pubsub/pubsub.go`
``` // Listeners for active=true flow control. When true is sent to a listener, // publishing should pause until false is sent to listeners. flows []chan bool ``` ``` NotifyFlow...
Hi, We're using amqp library to publish messages to a Queue, We've encountered 2 issues here 1. Same connection cannot be reused if we try to publish via goroutines. An...
Hello, I've been working on a project that should have a reconnection feature, in case a consumer were to disconnect due to being idle for a while, with a similar...
This fixes "x509: cannot verify signature: insecure algorithm SHA1-RSA" error with Go 1.18 and up in TestTLSHandshake. Thanks to @lnussbaum for the bug report; see https://bugs.debian.org/1008423
Hi, I followed the tutorial examples, but it reads all message from queue once, how can I read only one message from a queue? Appreciate!
Hi, I think I've found a bug with `Connection.Channel()`: sometimes the call is blocked indefinitely. My scenario: I've got a queue in a vhost. I start to consume on this...
Similar to issue mentioned in the thread : https://github.com/streadway/amqp/issues/416 Hi, I am facing the same issue in the above thread with amqp.Dial, if the username or password has "#" symbol,...
