mirror of
git://xwords.git.sourceforge.net/gitroot/xwords/xwords
synced 2025-02-11 08:48:06 +01:00
revert test for connectedness in mqtt shutdown
An assertion's firing indicating I don't understand what's going on. Let's study some more first.
This commit is contained in:
parent
d0b180a41d
commit
4ab88eb572
1 changed files with 4 additions and 10 deletions
|
@ -489,22 +489,16 @@ public class MQTTUtils extends Thread
|
||||||
String action = null;
|
String action = null;
|
||||||
IMqttToken token = null;
|
IMqttToken token = null;
|
||||||
try {
|
try {
|
||||||
boolean isConnected = client.isConnected();
|
|
||||||
switch ( ii ) {
|
switch ( ii ) {
|
||||||
case 0:
|
case 0:
|
||||||
if ( isConnected ) {
|
action = "unsubscribe";
|
||||||
action = "unsubscribe";
|
token = client.unsubscribe( mTopics );
|
||||||
token = client.unsubscribe( mTopics );
|
|
||||||
}
|
|
||||||
break; // not continue, which skips the Log() below
|
break; // not continue, which skips the Log() below
|
||||||
case 1:
|
case 1:
|
||||||
if ( isConnected ) {
|
action = "disconnect";
|
||||||
action = "disconnect";
|
token = client.disconnect();
|
||||||
token = client.disconnect();
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case 2:
|
case 2:
|
||||||
Assert.assertTrueNR( !isConnected );
|
|
||||||
action = "close";
|
action = "close";
|
||||||
client.close();
|
client.close();
|
||||||
break;
|
break;
|
||||||
|
|
Loading…
Add table
Reference in a new issue