RabbitMQ Stream - Consumer is not reconnecting after RabbitMQ service restarts.

[praveengopalan]

Describe the bug

I am new to rabbitmq stream, I have created two separate applications for publishing and subscribing rabbitmq stream messages. When I restart rabbitmq service the producer app reconnects successfully. However, the consumer app is not. I am getting below error message.

producer and consumer code attached.

GettingStartedProducer.txt
GettingStartedConsumer.txt

Reproduction steps

1. start producer and consumer app
2. stop rabbitmq service
3. start rabbitmq service
   ...

Expected behavior

Consumer reconnect back

Additional context

No response

[michaelklishin]

Please put together an executable way of reproducing and share node logs. We do not guess in this community.

All that can be suggested from these screenshots is that the client did try to connect or reconnect (the output is incomplete) and that failed with

No connection could be made … target machine actively refused it

which is TCP speak for "the connection was refused or there was no process listening on the target hostname:port".

This client uses a back-off reconnection strategy by default, so each failed attempt will increase the interval it waits before the next attempt to reconnect. Perhaps after Nth attempt to reconnect the interval grows to tens of seconds. With an executable example anyone could quickly verify this, in particular by taking a traffic capture and observing inbound TCP connection attempts on the RabbitMQ Stream protocol port.

[Gsantomaggio]

Describe the bug

I am new to rabbitmq stream, I have created two separate applications for publishing and subscribing rabbitmq stream messages. When I restart rabbitmq service the producer app reconnects successfully. However, the consumer app is not. I am getting below error message.

We'd need also the rabbitmq version and the client version.

Yesterday we released the 1.8.0 version focus on reconnecting

[Gsantomaggio]

@praveengopalan, looking at the logs, you are using an old client version.
Please update to the last version (1.8.0) and try this:
https://github.com/rabbitmq/rabbitmq-stream-dotnet-client/tree/main/docs/ReliableClient

[praveengopalan]

@Gsantomaggio client version upgraded to 1.8.0 and it is working fine

[Gsantomaggio]

Ok great!
Closed via #359 (reply in thread)