v0.26.2

Changelog

• 3b5f05d AMQP-1. consumer: only set consumer priority when > 0
• 4622b44 Explicitly close sender/received
• 816c53b Tweak joining the memberlist (#61)

v0.26.1

Changelog

• 3b5f05d AMQP-1. consumer: only set consumer priority when > 0
• 4622b44 Explicitly close sender/received
• 816c53b Tweak joining the memberlist (#61)

v0.26.0

Changelog

• basic AMQP 0.9.1 support
• Add --amqp-to
• More accurate TOTAL rates
• rename OMQ_FGROF -> OMQ_FGPROF (typo)
• Reintroduce --amqp-send-settled
• Remove --max-in-flight max of 256
• Use & in AMQP filter expressions

v0.25.0

Changelog

• 5b5119b Add session expiry option in MQTTv5
• 1098073 Handle errors better in AMQP send()
• fe4e84e Ignore context cancelled from AMQP SendWithReceipt
• a764691 Ignore context cancelled from MQTTv5 Publish
• 513b5de Remove --amqp-send-settled
• 8f0360a Remove outdated comment
• d18159d get rid of some context.TODO()s
• 1648788 go-amqp 1.4.0-beta.1

v0.24.0

Changelog

• a01b262 Don't re-declare queues
• c87006f Improve delayed consumer startup
• 4b1a433 Publishers start synchronously; refactors
• fcdd23f Refactors

v0.23.0

Changelog

• 02a3957 AMQP async publish
• 5ecc5a4 Cleanup async publishing commit
• 537973a Refactor management, add --management-uri
• 6b02ac1 Refactor metrics
• 771e6a4 Remove _client package suffixes
• 8ee95df Remove a few tests
• 56b3720 go get -u ./... && go mod tidy
• a782fd6 remove unused metricServer field

v0.22.0

Changelog

• 93a893b Add --exchange for explicity
• 3aa812a Fix & refactor binding calculation
• 4af42fd Update README

v0.21.2

Changelog

• 42f31ef Handle interrupt in MQTTv5
• 07d4c6d Pass credentials in MQTTv5

v0.21.1

Changelog

• c8ebc8f Don't print message rates until > 0
• b39d6fc FIX: use the right QoS for MQTT5 consumers
• 4d36672 Handle ^C while creating a sender
• c6b6c5b Refactor MQTT
• 5477de3 Remove a redundant argument
• 6e36fea Remove debug log
• 703e262 check err
• 18d67ed refactors

v0.21.0

Changelog

• 6cd4934 Missing files
• 2635a90 More contexts...
• 084073e Replace k8s client-go with an HTTP request
• 0aedcbf Tests around process termination
• 3985f8e Unfocus test
• 400d515 Unfocus tests
• 893fe9f gofumpt