Skip to content

Commit 63742ce

Browse files
authored
Merge pull request rusfearuth#1 from kamwong3/master
enable the mqttOptions.setWill
2 parents 1dfd5ec + aa5a8ad commit 63742ce

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

android/src/main/java/com/tuanpm/RCTMqtt/RCTMqtt.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ private void createClient(@NonNull final ReadableMap params)
143143
}
144144
if (params.hasKey("willtopic"))
145145
{
146-
defaultOptions.putString("willMsg", params.getString("willMsg"));
146+
defaultOptions.putString("willtopic", params.getString("willtopic"));
147147
}
148148
if (params.hasKey("willQos"))
149149
{
@@ -230,7 +230,9 @@ public X509Certificate[] getAcceptedIssuers()
230230

231231
if (options.getBoolean("will"))
232232
{
233-
// WTF?
233+
String topic = options.getString("willtopic");
234+
log("[ MQTT ] setWill"+topic);
235+
mqttOptions.setWill(topic, options.getString("willMsg").getBytes(), options.getInt("willQos"), options.getBoolean("willRetainFlag"));
234236
}
235237

236238
memPer = new MemoryPersistence();
@@ -555,4 +557,4 @@ private void log(@NonNull final String message)
555557
final String tag = new StringBuilder(TAG).append(" ").append(clientRef).toString();
556558
Log.d(tag, message);
557559
}
558-
}
560+
}

0 commit comments

Comments
 (0)