Receive Path

QoS 0

Client -> Haka: read call Haka <- Socket: recv publish(QoS=0) Client <- Haka: on_publish call Client -> Haka: on_publish return Client <- Haka: read return

QoS 1

Client -> Haka: read call Haka <- Socket: recv publish(QoS=1) Client <- Haka: on_publish call Client -> Haka: on_publish return note right: enqueue puback Client <- Haka: read return == ... == Client -> Haka: write call Haka -> Socket: send puback note right: dequeue puback Client <- Haka: write return

QoS 1 with Pre-Ack Disconnect

Client -> Haka: read call Haka <- Socket: recv publish(QoS=1) Client <- Haka: on_publish call Client -> Haka: on_publish return note right: enqueue puback Client <- Haka: read return == socket disconnect, reactor start, puback cleared == Client -> Haka: read call Haka <- Socket: recv publish(QoS=1, dupe=True) Client <- Haka: on_publish call Client -> Haka: on_publish return note right: enqueue puback Client <- Haka: read return == ... == Client -> Haka: write call Haka -> Socket: send puback note right: dequeue puback Client <- Haka: write return

QoS 2

Client -> Haka: read call Haka <- Socket: recv publish(QoS=2) Client <- Haka: on_publish call Client -> Haka: on_publish return note right: enqueue pubrec Client <- Haka: read return == ... == Client -> Haka: write call Haka -> Socket: send pubrec note right: dequeue pubrec Client <- Haka: write return == ... == Client -> Haka: read call Haka <- Socket: recv pubrel Client <- Haka: on_pubrel call Client -> Haka: on_pubrel return note right: enqueue pubcomp Client <- Haka: read return == ... == Client -> Haka: write call Haka -> Socket: send pubcomp note right: dequeue pubcomp Client <- Haka: write return