Skip to content

Commit 3236c0a

Browse files
jpwsuttonIan Craggs
authored andcommitted
Bug 459360 - Incoming response does not issue a notify, instead waits for maximum TimeToWait
Added token.internalTok.notifyComplete(); in ClientState.notifyResult. Signed-off-by: James Sutton <james.sutton@uk.ibm.com>
1 parent 1191172 commit 3236c0a

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

  • org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/ClientState.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1034,7 +1034,8 @@ protected void notifyResult(MqttWireMessage ack, MqttToken token, MqttException
10341034
final String methodName = "notifyResult";
10351035
// unblock any threads waiting on the token
10361036
token.internalTok.markComplete(ack, ex);
1037-
1037+
token.internalTok.notifyComplete();
1038+
10381039
// Let the user know an async operation has completed and then remove the token
10391040
if (ack != null && ack instanceof MqttAck && !(ack instanceof MqttPubRec)) {
10401041
//@TRACE 648=key{0}, msg={1}, excep={2}

0 commit comments

Comments
 (0)