A client library for RabbitMQ streams
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.4.1...v1.4.2
Reduce memory allocation in handlerDeliver
by @hiimjako in https://github.com/rabbitmq/rabbitmq-stream-go-client/pull/294
This fix improves the ~20% performance. See https://github.com/rabbitmq/rabbitmq-stream-go-client/pull/294#issuecomment-2058478342
Bump github.com/klauspost/compress from 1.17.7 to 1.17.8 by @dependabot in https://github.com/rabbitmq/rabbitmq-stream-go-client/pull/292
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.4.0...v1.4.1
The version contains the Super Stream implementation with Single Active Consumer. See the full example here: https://github.com/rabbitmq/rabbitmq-stream-go-client/tree/main/examples/super_stream
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.3.3...v1.4.0
The main feature is Stream Filtering in https://github.com/rabbitmq/rabbitmq-stream-go-client/pull/281; see the blog post for more details. Example here
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.3.2...v1.3.3
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.3.1...v1.3.2
The version introduces:
ReliableProducer
ReliableConsumer
The new structs are built up of the standard producer
and consumer
; see the complete documentation here
Confirmation timeout The client will raise timeout error
on the confirmation handler If it does not receive a confirmation within a timeout:
stream.NewProducerOptions().SetConfirmationTimeOut(5*time.Second).
ClientProvidedName:
stream.NewProducerOptions().
SetConfirmationTimeOut(5*time.Second).
SetClientProvidedName(fmt.Sprintf("producer-%d", I)),
The name is shown on the management UI
Here you can find a complete example with Reliable*
part, timeout and ClientProvidedName
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.3.0...v1.3.1
Golang 1.8 is now required
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.2.1...v1.3.0
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.2.0...v1.2.1
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.1.2...v1.2.0
Full Changelog: https://github.com/rabbitmq/rabbitmq-stream-go-client/compare/v1.1.1...v1.1.2