Skip to content

Releases: rabbitmq/rabbitmq-stream-go-client

v0.9-alpha

16 Jul 08:43
Compare
Choose a tag to compare

v0.8-alpha

05 Jul 07:46
033ffd8
Compare
Choose a tag to compare
  • 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

20 Jun 14:11
Compare
Choose a tag to compare
  • refactor coordinator #45. Reduce the mutex lock
  • Messages interface #47 ( first implementation)
  • change the store API name: #48

v0.6-alpha

10 Jun 19:10
Compare
Choose a tag to compare
 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

23 May 17:29
dd2f9a0
Compare
Choose a tag to compare
  • #38
  • change port to 5552 #39
  • Add channels to handle closing and confirmations #38

v0.4-alpha

12 May 10:44
Compare
Choose a tag to compare
v0.4-alpha Pre-release
Pre-release

add support for environment #37

v0.3-alpha

17 Apr 15:37
c4ee972
Compare
Choose a tag to compare
v0.3-alpha Pre-release
Pre-release
  • exctract codec

v0.2-alpha

08 Apr 16:11
5d2fb3c
Compare
Choose a tag to compare
v0.2-alpha Pre-release
Pre-release
Update README.md

Go Stream client 0.1-alpha

06 Apr 09:30
350481f
Compare
Choose a tag to compare
Pre-release

First Alpha