amqp
amqp copied to clipboard
vcabbage
AMQP 1.0 client library for Go.
Related with Azure/azure-event-hubs-go#131. After some investigation, I find that the msg received in the below method only has three Annotations: https://github.com/vcabbage/amqp/blob/7c41f1a1270d0d35b778b09b70c0e3063cd088af/client.go#L1810-L1839  The missing `x-opt-partition-id` annotation prevents the event hubs...
Hi, How can I limit my receiver to receive only 5 or another number of unack message to avoid to receive all messages that are in the queue ? Thanks
Currently when receiving messages with batching enabled there's no guarantee that queued dispositions will be sent when the link is closed. A final batch of dispositions should be sent before...
Hello, I try to get this package work with RabbitMQ and the AMQP 1 plugin. I can get it work with Go and Azure or C# and RabbitMQ but not...
Similar usage-scenario to #109 Scenario: 1) Connecting, creating Session and Sender 2) Send some messages 3) Do some long work 4) To gracefully handle long idle-periods we call Sender.Close after...
Hi, I'm seeing the following when using the library with Azure ServiceBus. The program is making a session and sender and then holding it open, sometime for >10Mins, without sending...
Currently it's possible to call accept/modify/reject/release multiple times on the same message and have a disposition sent multiple times. These are all terminal delivery states and only the first call...
Unsure how widely used sequences are. Low on the priority list unless someone asks for them. https://github.com/vcabbage/amqp/blob/ee6eb7ef6e2355b46a573b0b1799f76259f2ea47/types.go#L1710-L1712
https://github.com/vcabbage/amqp/blob/ee6eb7ef6e2355b46a573b0b1799f76259f2ea47/types.go#L713 https://github.com/vcabbage/amqp/blob/ee6eb7ef6e2355b46a573b0b1799f76259f2ea47/types.go#L893
https://github.com/vcabbage/amqp/blob/ee6eb7ef6e2355b46a573b0b1799f76259f2ea47/types.go#L560-L589