- 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 = falsein 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