ntex-amqp 5.8.0

use ntex::service::{boxed::BoxService, fn_factory_with_config};
use ntex_amqp::{error::AmqpError, error::LinkError, server};

async fn server(
    link: server::Link<()>,
) -> Result<BoxService<server::Transfer, server::Outcome, AmqpError>, LinkError> {
    println!("OPEN LINK: {:?}", link);
    Err(LinkError::force_detach().description("unimplemented"))
}

#[ntex::main]
async fn main() -> std::io::Result<()> {
    // std::env::set_var("RUST_LOG", "trace,ntex_io=info");
    env_logger::init();

    ntex::server::Server::builder()
        .bind("amqp", "127.0.0.1:5671", async |_| {
            server::Server::build(|con: server::Handshake| async move {
                match con {
                    server::Handshake::Amqp(con) => {
                        let con = con.open().await.unwrap();
                        Ok(con.ack(()))
                    }
                    server::Handshake::Sasl(_) => Err(AmqpError::not_implemented()),
                }
            })
            .finish(
                server::Router::builder()
                    .service("test", fn_factory_with_config(server))
                    .build(),
            )
        })?
        .workers(1)
        .run()
        .await
}