Struct ntex_mqtt::v5::MqttServer

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

Mqtt Server

Implementations

impl<Io, St, C> MqttServer<Io, St, C, DefaultControlService<St, C::Error>, DefaultPublishService<St, C::Error>> where
    St: 'static,
    C: ServiceFactory<Config = (), Request = Handshake<Io>, Response = HandshakeAck<Io, St>> + 'static,
    C::Error: Debug, 

pub fn new<F>(handshake: F) -> Self where
    F: IntoServiceFactory<C>, 

Create server factory and provide handshake service

impl<Io, St, C, Cn, P> MqttServer<Io, St, C, Cn, P> where
    Io: AsyncRead + AsyncWrite + Unpin + 'static,
    St: 'static,
    C: ServiceFactory<Config = (), Request = Handshake<Io>, Response = HandshakeAck<Io, St>> + 'static,
    C::Error: Debug,
    Cn: ServiceFactory<Config = Session<St>, Request = ControlMessage<C::Error>, Response = ControlResult> + 'static,
    P: ServiceFactory<Config = Session<St>, Request = Publish, Response = PublishAck> + 'static, 

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

Set handshake timeout in millis.

Handshake includes connect packet and response connect-ack. By default handshake timeuot is disabled.

pub fn disconnect_timeout(self, val: u16) -> Self

Set server connection disconnect timeout in milliseconds.

Defines a timeout for disconnect connection. If a disconnect procedure does not complete within this time, the connection get dropped.

To disable timeout set value to 0.

By default disconnect timeout is set to 3 seconds.

pub fn max_size(self, size: u32) -> 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 receive_max(self, val: u16) -> Self

Set receive max

Number of in-flight publish packets. By default receive max is set to 15 packets. To disable timeout set value to 0.

pub fn max_topic_alias(self, val: u16) -> Self

Number of topic aliases.

By default value is set to 32

pub fn max_qos(self, qos: QoS) -> Self

Set server max qos setting.

By default max qos is not set`

pub fn control<F, Srv>(self, service: F) -> MqttServer<Io, St, C, Srv, P> where
    F: IntoServiceFactory<Srv>,
    Srv: ServiceFactory<Config = Session<St>, Request = ControlMessage<C::Error>, Response = ControlResult> + 'static,
    C::Error: From<Srv::Error> + From<Srv::InitError>, 

Service to handle control messages

pub fn publish<F, Srv>(self, publish: F) -> MqttServer<Io, St, C, Cn, Srv> where
    F: IntoServiceFactory<Srv> + 'static,
    C::Error: From<Srv::Error> + From<Srv::InitError>,
    Srv: ServiceFactory<Config = Session<St>, Request = Publish, Response = PublishAck> + 'static,
    Srv::Error: Debug,
    PublishAck: TryFrom<Srv::Error, Error = C::Error>, 

Set service to handle publish packets and create mqtt server factory

impl<Io, St, C, Cn, P> MqttServer<Io, St, C, Cn, P> where
    Io: AsyncRead + AsyncWrite + Unpin + 'static,
    St: 'static,
    C: ServiceFactory<Config = (), Request = Handshake<Io>, Response = HandshakeAck<Io, St>> + 'static,
    C::Error: From<Cn::Error> + From<Cn::InitError> + From<P::Error> + From<P::InitError> + Debug,
    Cn: ServiceFactory<Config = Session<St>, Request = ControlMessage<C::Error>, Response = ControlResult> + 'static,
    P: ServiceFactory<Config = Session<St>, Request = Publish, Response = PublishAck> + 'static,
    P::Error: Debug,
    PublishAck: TryFrom<P::Error, Error = C::Error>, 

pub fn finish(
    self
) -> impl ServiceFactory<Config = (), Request = Io, Response = (), Error = MqttError<C::Error>>

Set service to handle publish packets and create mqtt server factory