Struct ntex_amqp::server::Server

pub struct Server<Io, St, Cn: ServiceFactory> { /* fields omitted */ }

Server dispatcher factory

Methods

impl<Io, St, Cn> Server<Io, St, Cn> where
    St: 'static,
    Io: AsyncRead + AsyncWrite + Unpin + 'static,
    Cn: ServiceFactory<Config = (), Request = Either<Connect<Io>, Sasl<Io>>, Response = ConnectAck<Io, St>> + 'static, 

pub fn new<F>(connect: F) -> Self where
    F: IntoServiceFactory<Cn>, 

Create server factory and provide connect service

pub fn config(self, config: Configuration) -> Self

Provide connection configuration

pub fn max_size(self, size: usize) -> Self

Set max inbound frame size.

If max size is set to 0, size is unlimited. By default max size is set to 0

pub fn handshake_timeout(self, timeout: u64) -> Self

Set handshake timeout in millis.

By default handshake timeuot is disabled.

pub fn control<F, S>(self, f: F) -> Self where
    F: IntoServiceFactory<S>,
    S: ServiceFactory<Config = (), Request = ControlFrame<St>, Response = (), InitError = ()> + 'static,
    S::Error: Into<LinkError>, 

Service to call with control frames

pub fn disconnect<F, Out>(self, disconnect: F) -> Self where
    F: Fn(&mut St, Option<&ServerError<Cn::Error>>) -> Out + 'static,
    Out: Future + 'static, 

Callback to execute on disconnect

Second parameter indicates error occured during disconnect.

pub fn finish<F, Pb>(
    self,
    service: F
) -> impl ServiceFactory<Config = (), Request = Io, Response = (), Error = ServerError<Cn::Error>> where
    F: IntoServiceFactory<Pb>,
    Pb: ServiceFactory<Config = State<St>, Request = Link<St>, Response = ()> + 'static,
    Pb::Error: Display + Into<Error>,
    Pb::InitError: Display + Into<Error>, 

Set service to execute for incoming links and create service factory