Struct ConnAckPacket 

pub struct ConnAckPacket {
    pub session_present: bool,
    pub reason_code: ReasonCode,
    pub properties: Properties,
    pub protocol_version: u8,
}

MQTT CONNACK packet

Fields

session_present: bool

Session present flag

reason_code: ReasonCode

Connect reason code

properties: Properties

CONNACK properties (v5.0 only)

protocol_version: u8

Protocol version (for encoding/decoding)

Implementations

impl ConnAckPacket

pub fn new(session_present: bool, reason_code: ReasonCode) -> Self

Creates a new CONNACK packet

pub fn new_v311(session_present: bool, reason_code: ReasonCode) -> Self

Creates a new v3.1.1 CONNACK packet

pub fn with_session_expiry_interval(self, interval: u32) -> Self

Sets the session expiry interval

pub fn with_receive_maximum(self, max: u16) -> Self

Sets the receive maximum

pub fn with_maximum_qos(self, qos: u8) -> Self

Sets the maximum QoS

pub fn with_retain_available(self, available: bool) -> Self

Sets whether retain is available

pub fn with_maximum_packet_size(self, size: u32) -> Self

Sets the maximum packet size

pub fn with_assigned_client_id(self, id: String) -> Self

Sets the assigned client identifier

pub fn with_topic_alias_maximum(self, max: u16) -> Self

Sets the topic alias maximum

pub fn with_reason_string(self, reason: String) -> Self

Sets the reason string

pub fn with_wildcard_subscription_available(self, available: bool) -> Self

Sets whether wildcards are available

pub fn with_subscription_identifier_available(self, available: bool) -> Self

Sets whether subscription identifiers are available

pub fn with_shared_subscription_available(self, available: bool) -> Self

Sets whether shared subscriptions are available

pub fn with_server_keep_alive(self, keep_alive: u16) -> Self

Sets the server keep alive

pub fn with_response_information(self, info: String) -> Self

Sets the response information

pub fn with_server_reference(self, reference: String) -> Self

Sets the server reference

pub fn with_authentication_method(self, method: String) -> Self

Sets the authentication method

pub fn with_authentication_data(self, data: Vec<u8>) -> Self

Sets the authentication data

pub fn with_user_property(self, key: String, value: String) -> Self

Adds a user property

pub fn topic_alias_maximum(&self) -> Option<u16>

Gets the topic alias maximum from properties

pub fn receive_maximum(&self) -> Option<u16>

Gets the receive maximum from properties

pub fn maximum_packet_size(&self) -> Option<u32>

Gets the maximum packet size from properties

Trait Implementations

impl Clone for ConnAckPacket

fn clone(&self) -> ConnAckPacket

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConnAckPacket

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MqttPacket for ConnAckPacket

fn packet_type(&self) -> PacketType

Returns the packet type

fn encode_body<B: BufMut>(&self, buf: &mut B) -> Result<()>

Encodes the packet body (without fixed header)

fn decode_body<B: Buf>(buf: &mut B, _fixed_header: &FixedHeader) -> Result<Self>

Decodes the packet body (without fixed header)

fn flags(&self) -> u8

Returns the fixed header flags

fn encode<B: BufMut>(&self, buf: &mut B) -> Result<()>

Encodes the complete packet (with fixed header)