amqp
amqp copied to clipboard
vcabbage
AMQP 1.0 client library for Go.
I send messages to Amazon MQ. I have a connection and a session created on start up and sender gets created for each message. At start up the application is...
I will start off by saying that this library is awesome and the author is more awesome. He helped me directly by taking his own time to review my code...
Hi, dear: I called the function link.Close(ctx), and the link ( send or receive link) didn't be closed, the thread of this link still run in background ,it leads to...
It's become apparent that I don't have the time to properly maintain this library anymore. I don't want to be holding up continued development and feel that I should make...
When I connect qpid 1.38.0, it appears： 2019/12/31 10:31:46 Dialing AMQP server:unexpected protocol version 1.0.10 Qpid C++ 1.38.0 Component | Languages | Platforms | AMQP versions C++ broker | C++...
Test code ``` func TestSendReceive(t *testing.T) { c, err := amqp.Dial("amqp://") require.NoError(t, err) defer c.Close() ssn, err := c.NewSession() require.NoError(t, err) r, err := ssn.NewReceiver(amqp.LinkAddressDynamic()) require.NoError(t, err) s, err :=...
When a connection is lost to the server, there is no way for an application to know the connection is lost. The client, conn, and session sit idle as if...
vcabbage currently only acts as a client, and does not support incoming lines Add support for listening on a server socket and accepting incoming links and sessions (for both client...
I have two components that use Amazon MQ as their common AMQP provider. Both components are in separate Linux CentOS EC2 instances (however, I was able to reproduce this issue...
The current Sender.Send() blocks for the remote disposition. This is fine for many applications, but it does not allow sending at full network throughput because it forces the sender t...