How to implement a simple reconnect logic?

[Ks89]

Is there a suggested way (or even better a runnable example) to implement reconnect in these cases:

• it starts, but it isn't able to connect to RabbitMQ
• it's already running, but suddenly the connection is not available

Thanks

[ragyabraham]

pub struct RabbitConnect {
    pub host: String,
    pub port: u16,
    pub username: String,
    pub password: String,
}

pub async fn connect_rabbitmq(connection_details: &RabbitConnect) -> Result<Connection> {
    let mut res = Connection::insecure_open(
        format!(
            "amqp://{}:{}@{}:{}",
            connection_details.username,
            connection_details.password,
            connection_details.host,
            connection_details.port
        )
        .as_str(),
    );

    while res.is_err() {
        println!("trying to connect after error");
        sleep(Duration::from_millis(2000)).await;
        res = Connection::insecure_open(
            format!(
                "amqp://{}:{}@{}:{}",
                connection_details.username,
                connection_details.password,
                connection_details.host,
                connection_details.port
            )
            .as_str(),
        );
    }
    res
}