Publish confirmation channel is throwing tcp: missing address

[govindkailas]

I am trying the getting_started.go but it seems to be failing at

rabbitmq-stream-go-client/examples/getting_started.go

Line 77 in 9b8f809

handlePublishConfirm(chPublishConfirm)

with dial tcp: missing address exit status 1. I can see that the stream is getting created with the UUID.

I added some extra Println to see where it is breaking.

 go run .
Getting started with Streaming client for RabbitMQ
Connecting to RabbitMQ streaming ...
Stream Declared! --> e12772bc-46b2-488d-8b0c-4fe282697ac6
Created a new producer for the Stream --> e12772bc-46b2-488d-8b0c-4fe282697ac6
dial tcp: missing address exit status 1

RabbitMQ instance is created using the operator as mentioned here and the service is exposed as a Loadbalancer.

Any clues on why it is complaining about the missing address?

[Gsantomaggio]

you need to configure the load balancer options, see https://github.com/rabbitmq/rabbitmq-stream-go-client

Load balancer section

There is an example here:

https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/main/examples/README.md

[govindkailas]

Thanks, used the proxy example and it worked like a charm. It would be nice to have a little more description on where and why it failed instead of just saying dial tcp: missing address exit status 1

[Gsantomaggio]

You are right.
We are working on a total new version of this client.

See #215

Where the errors are handled in a better way.

[marcosbis]

Hi there,
Im having the same error when trying to connect a cluster
this is my config:

addresses := []string{
		"rabbitmq-stream+tls://guest:[email protected]:5551/dev",
		"rabbitmq-stream+tls://guest:[email protected]:5551/dev",
		"rabbitmq-stream+tls://guest:[email protected]:5551/dev"}



// 	addressResolver := stream.AddressResolver{
//		Host: "my1.sslcloud.server",
//		Port: 5551,
//	}

	env, err := stream.NewEnvironment(
		stream.NewEnvironmentOptions().
		//	SetAddressResolver(addressResolver).
			SetTLSConfig(&tls.Config{InsecureSkipVerify: true}).
			SetUris(addresses))

	CheckErr(err)
	fmt.Println("Connect")

	streamName := "test-streamer"
	err = env.DeclareStream(streamName,
		stream.NewStreamOptions().
			SetMaxLengthBytes(stream.ByteCapacity{}.GB(2)))

	CheckErr(err)
	fmt.Println("Connect1")

	// Get a new producer for a stream
	producer, err := env.NewProducer(streamName, nil)
	CheckErr(err)
  fmt.Println("Continue to consumer")
-----
this will throw:
dial tcp: missing address exit status 1

if I enable the address resolver I dont get any error on creating the producer but the next lines are never triggered, I shouldn't need to add an address resolver when connected direct to the cluster, right?

[Gsantomaggio]

The client needs to lookup the rabbitmq nodes name.

What it the result of:

rabbitmqctl cluster_status

you should have something like:

rabbitmqctl cluster_status
Cluster status of node rabbit@mynodename ...
Basics

Cluster name: rabbit@xxxxxxx
Total CPU cores available cluster-wide: 8

Disk Nodes

rabbit@mynodename
......