Jeffrey Devloo

Patch for the issue: ``` Index: org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP UTF-8 =================================================================== diff --git a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java --- a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java (revision f4e0db802a4433645ef011e711646a09ec9fae89) +++ b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java (revision 7fcaefef9bf9ed5cfa68af4086f5f77aa47b81cc) @@ -19,6 +19,7 @@...

Digging even deeper into the code I've found that it's because of the `MqttIncomingPublishService#onPublish` invoking `MqttIncomingPublishFlows#findMatching` only reading from global flows. The `subscribedFlows` contains the right subscription identifier which can...