amqp

amqp copied to clipboard

liutaot

Channel blocks despite connection is closed

5

Hi, I have an issue with the library 1.0.0. It seems to be a deadlock, the issue is not always reproducible, locally I start my application, pause it to timeout...

melardev

It seems that this repository has officially moved into github.com/rabbitmq/amqp091-go. What do you think about adding a note on top of the README about this? I was not able to...

andygrunwald

In the example, the return value of the Steam method amqp.delivery will not cancel. When I restart Rabbitmq, amqp.delivery will not be canceled. Because this place is blocked

jeffmingup

Add GetNextPublishSeqNo() for Channel in confirm mode

4

`GetNextPublishSeqNo` method on `Channel` will be very useful for handling of especailly NACKed messages to keep track of message going to be published so that those can be republished or...

kamal-github

Please update version tag

4

Last version tag is v.1.0.0 There are two important fixes that have been deployed after it. Please cut the tag for newer commits

kirill-kostenetskyi

Why use struct instead of pointer？

1

https://github.com/streadway/amqp/blob/e6b33f460591b0acb2f13b04ef9cf493720ffe17/connection.go#L223 ``` func Open(conn io.ReadWriteCloser, config Config) (*Connection, error) { c := &Connection{ conn: conn, writer: &writer{bufio.NewWriter(conn)}, channels: make(map[uint16]*Channel), rpc: make(chan message), sends: make(chan time.Time), errors: make(chan *Error, 1), deadlines:...

super9du

concurrent publish occur: "Exception (504) Reason: "channel/connection is not open"

4

go version: go1.14.1 windows/amd64 rabbitmq version: RabbitMQ 3.8.4 Erlang 23.0 my code is: ``` package main import ( "fmt" "github.com/streadway/amqp" ) var ( conn = &amqp.Connection{} ch = &amqp.Channel{} )...

littlejiancc

I'm running a simple pubsub application in k8s cluster. The publisher and the subscriber are threads in the same process. The publisher publishes messages to 3 fanout exchanges every 0.5...

dmitsh

Fix AMQPLAIN authentication mechanism

2

Fixes #514. The current AMQPLAIN implementation does not work with `rabbitmq` out-of-the-box. I could not find an official reference for that authentication mechanism. Looking at other implementations ([rust](https://github.com/CleverCloud/amq-protocol/blob/master/protocol/src/auth.rs#L45), [python](https://github.com/celery/py-amqp/blob/7300741f9fc202083e87abd10e1cb38c28efad92/amqp/sasl.py#L48)) it...

hodbn