Releases: rabbitmq/rabbitmq-stream-go-client
Releases · rabbitmq/rabbitmq-stream-go-client
v0.9-alpha
v0.8-alpha
- Add smart publish #52
- Add Direct connection, it is possible to use direct connection like:
direct, err := stream.NewDirectClient(&stream.Broker{ Host: "localhost", Port: "5552", User: "guest", Vhost: "/", Password: "guest", Scheme: "rabbitmq-stream", })
v0.7-alpha
v0.6-alpha
- Protocol Change rabbitmq/rabbitmq-server#3097
- Add support for multi-broker url:
addresses := []string{"rabbitmq-stream://guest:guest@localhost:5552/%2f",
"rabbitmq-stream://guest:guest@localhost:5553/%2f",
"rabbitmq-stream://guest:guest@localhost:5554/%2f"}
env, err := stream.NewEnvironment(stream.NewEnvironmentOptions().SetUris(addresses))
- Add support for
Confirmation = false
in case the client can't send the message:
for confirmed := range confirms {
for _, msg := range confirmed {
if msg.Confirmed { ...}
- First implementation of
ha_producer
- still experimental
v0.5-alpha
v0.4-alpha
add support for environment #37
v0.3-alpha
- exctract codec
v0.2-alpha
Update README.md
Go Stream client 0.1-alpha
First Alpha