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", })