We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4e53347 commit d32134bCopy full SHA for d32134b
1 file changed
org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsSender.java
@@ -1,5 +1,5 @@
1
/*******************************************************************************
2
- * Copyright (c) 2009, 2018 IBM Corp.
+ * Copyright (c) 2009, 2019 IBM Corp.
3
*
4
* All rights reserved. This program and the accompanying materials
5
* are made available under the terms of the Eclipse Public License v1.0
@@ -136,7 +136,7 @@ public void run() {
136
} else {
137
MqttToken token = message.getToken();
138
if (token == null) {
139
- tokenStore.getToken(message);
+ token = tokenStore.getToken(message);
140
}
141
// While quiescing the tokenstore can be cleared so need
142
// to check for null for the case where clear occurs
0 commit comments