Skip to content

remove the Recovery limits #42

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 1 commit into from
Closed

Conversation

Gsantomaggio
Copy link
Member

Remove the backoff limits.
Closes: #41

@OneSeven can you please try?

RecoveryConfiguration: &RecoveryConfiguration{
				ActiveRecovery:           true,
				BackOffReconnectInterval: 0,
				MaxReconnectAttempts:     500,
				Jitter:                   0,
			},

Signed-off-by: Gabriele Santomaggio <[email protected]>
@OneSeven
Copy link

github.com/rabbitmq/rabbitmq-amqp-go-client@remove_reconnect_limits
I used the branch for testing and it didn't work.

@Gsantomaggio
Copy link
Member Author

@OneSeven,

it didn't work.

It is not enough to understand

Can you please create a repo with your issue and instructions for reproducing it step by step?

@OneSeven
Copy link

@OneSeven,

it didn't work.

It is not enough to understand

Can you please create a repo with your issue and instructions for reproducing it step by step?

https://github.com/rabbitmq/rabbitmq-amqp-go-client/blob/remove_reconnect_limits/docs/examples/getting_started/main.go

I used the sample code, set the AmqpConnOptions parameter, and started rabbitmq4.0. After the sample code was output, I manually shut down rabbitmq-server and started it again after a while, but the connection was not restored.

@Gsantomaggio
Copy link
Member Author

Still not able to reproduce the issue, it works without problems.

2025/03/18 10:10:07 INFO [Consumer] "Received message"="[Hello, World!99]"

<<Here is where I stop the server>>

2025/03/18 10:10:28 ERROR [Consumer] "Error receiving message"="*Error{Condition: amqp:internal-error, Description: Connection forced: \"broker forced connection closure with reason 'shutdown'\", Info: map[]}"
2025/03/18 10:10:28 INFO [connection] "Status changed"="From: open, To: closed, Error: *Error{Condition: amqp:internal-error, Description: Connection forced: \"broker forced connection closure with reason 'shutdown'\", Info: map[]}"
2025/03/18 10:10:28 ERROR connection closed unexpectedly error="*Error{Condition: amqp:internal-error, Description: Connection forced: \"broker forced connection closure with reason 'shutdown'\", Info: map[]}" ID=10b75419-ba21-4968-beb4-83941f6ecd29_1
2025/03/18 10:10:28 INFO Attempting reconnection attempt=1 delay=5.424706836s ID=10b75419-ba21-4968-beb4-83941f6ecd29_1
2025/03/18 10:10:28 INFO [connection] "Status changed"="From: closed, To: reconnecting"
2025/03/18 10:10:33 INFO Entity restart complete publisherFails=0 consumerFails=0
2025/03/18 10:10:33 INFO [connection] "Status changed"="From: reconnecting, To: open"

Again, please provide:

  1. every single step to reproduce the issue
  2. client logs
  3. server logs
  4. Rabbitmq Server version
  5. how to stop RabbitMQ ( ex docker, linux , etc)

Thank you

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Fixed time and unlimited number of disconnection and reconnection
2 participants