Move the execution of receivePublish for qos0 and qos1 into the Session onEventLoop

moquette-io / moquette

Java MQTT lightweight broker

http://moquette-io.github.io/moquette/

Apache License 2.0

2.3k stars 818 forks source link

Move the execution of receivePublish for qos0 and qos1 into the Session onEventLoop #654

Closed andsel closed 2 years ago

andsel commented 2 years ago

This PR wraps the execution of methods to handle the receive of PUB at qos0 and qos1 into the SessionEventLoop. While this processing didn't present any problem in being execute by the Netty's IO thread, to be adherent to the chosen architecture, is best to be in a session event loop thread.

andsel commented 2 years ago

cc @hylkevds

hylkevds commented 2 years ago

Makes sense :+1: