rabbitmq / rabbitmq-stream-go-client

A client library for RabbitMQ streams
MIT License
169 stars 20 forks source link

Ping rabbitmq / timeout #312

Closed plaluisalves closed 4 months ago

plaluisalves commented 5 months ago

Is your feature request related to a problem? Please describe.

Hi Guys, not sure if here is the right channel to ask, but is it possible to have a ping method for rabbitmq stream plugin or the timeout variable could be expose? I m start and stop the container for rabbitmq, and if the container is down, I try to connect, at first, I received an error related with a timeout, and the second time is more fast. The first error I got is this: 2024/06/07 14:12:30 [error] - timeout 10000 ns - waiting Code, operation: commandPeerProperties 2024/06/07 14:12:30 [error] - Can't set the peer-properties. Check if the stream server is running/reachable The seconde error is this: dial tcp 127.0.0.1:5552: connectex: No connection could be made because the target machine actively refused it.

Describe the solution you'd like

My question is, could this timeout be expose, and we define the timeout on EnvironmentOptions, I don't want to wait 10s just to find out that the server is down?

Describe alternatives you've considered

No response

Additional context

No response

Gsantomaggio commented 5 months ago

Yes. It makes sense, but it will be for all the RPC calls. Will add something like:

  .rpcTimeout(......)
plaluisalves commented 5 months ago

Thanks 😉

Gsantomaggio commented 5 months ago

@plaluisalves can you please try https://github.com/rabbitmq/rabbitmq-stream-go-client/pull/313?

plaluisalves commented 5 months ago

It is working! Thanks for the quick response and solution 😉

Gsantomaggio commented 4 months ago

FYI: https://github.com/rabbitmq/rabbitmq-stream-go-client/releases/tag/v1.4.5