rabbitmq-stream-go-client
rabbitmq-stream-go-client copied to clipboard
rabbitmq
A client library for RabbitMQ streams
need to invalidate [unconfirmed messages](https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/main/pkg/stream/producer.go#L22) a the moment the list in oubouded.
Ref https://github.com/rabbitmq/rabbitmq-server/pull/5321 Per [internal conversion](https://vmware.slack.com/archives/C039S4USVPG/p1659086921580689)
Implement the Single-Active Consumer feature. Java reference: https://rabbitmq.github.io/rabbitmq-stream-java-client/sac/htmlsingle/#single-active-consumer Single Active Consumer requires RabbitMQ 3.11 or more.
### Description The current implementation of `stream.Producer` and `stream.Consumer` use `stream.Coordinator`. This coordinator does a lot of things, like keeping track of the IDs used for communication, reconnection, keeping a...
The Java Client [supports Super Streams](https://rabbitmq.github.io/rabbitmq-stream-java-client/snapshot/htmlsingle/#super-streams) as an experimental feature. Super Streams are partitioned streams, with an arbitrary routing logic to route messages from a logical stream to a stream...
Make `frame_size` configurable. At the moment it uses the default configuration
Request to add basic comments to public-facing functions, as well as better descriptions of how/where to close producers/consumers to improve usability as opposed to relying on examples that do everything...
Bumps [github.com/onsi/ginkgo/v2](https://github.com/onsi/ginkgo) from 2.1.6 to 2.3.1. Release notes Sourced from github.com/onsi/ginkgo/v2's releases. v2.3.1 2.3.1 Fixes Several users were invoking ginkgo by installing the latest version of the cli via go...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [github.com/onsi/gomega](https://github.com/onsi/gomega) from 1.22.0 to 1.22.1. Release notes Sourced from github.com/onsi/gomega's releases. v1.22.1 1.22.1 Fixes When passed a context and no explicit timeout, Eventually will only timeout when the context...