Skip to content

Commit bbd3916

Browse files
jpwsuttonIan Craggs
authored andcommitted
Fix Bug 462619 - Change was reverted by accident. Putting back in.
Signed-off-by: James Sutton <james.sutton@uk.ibm.com> Change-Id: Ibadc46d43706be0ddb1dc588153f666cee2bc231
1 parent 2bc3953 commit bbd3916

1 file changed

Lines changed: 8 additions & 8 deletions

File tree

  • org.eclipse.paho.android.service/org.eclipse.paho.android.service/src/main/java/org/eclipse/paho/android/service

org.eclipse.paho.android.service/org.eclipse.paho.android.service/src/main/java/org/eclipse/paho/android/service/MqttAndroidClient.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ public void onServiceDisconnected(ComponentName name) {
152152
private Ack messageAck;
153153
private boolean traceEnabled = false;
154154

155-
private volatile boolean registerReceiver = false;
155+
private volatile boolean receiverRegistered = false;
156156
private volatile boolean bindedService = false;
157157

158158
/**
@@ -430,8 +430,8 @@ public IMqttToken connect(MqttConnectOptions options, Object userContext,
430430
myContext.startService(serviceStartIntent);
431431
myContext.bindService(serviceStartIntent, serviceConnection,
432432
Context.BIND_AUTO_CREATE);
433-
434-
registerReceiver(this);
433+
434+
if (!receiverRegistered) registerReceiver(this);
435435
}
436436
else {
437437
pool.execute(new Runnable() {
@@ -441,7 +441,7 @@ public void run() {
441441
doConnect();
442442

443443
//Register receiver to show shoulder tap.
444-
registerReceiver(MqttAndroidClient.this);
444+
if (!receiverRegistered) registerReceiver(MqttAndroidClient.this);
445445
}
446446

447447
});
@@ -454,7 +454,7 @@ private void registerReceiver(BroadcastReceiver receiver) {
454454
IntentFilter filter = new IntentFilter();
455455
filter.addAction(MqttServiceConstants.CALLBACK_TO_ACTIVITY);
456456
LocalBroadcastManager.getInstance(myContext).registerReceiver(receiver, filter);
457-
registerReceiver = true;
457+
receiverRegistered = true;
458458
}
459459

460460
/**
@@ -1710,10 +1710,10 @@ public void disconnectForcibly(long quiesceTimeout, long disconnectTimeout)
17101710
* IntentReceiver leaks.
17111711
*/
17121712
public void unregisterResources(){
1713-
if(myContext != null && registerReceiver){
1713+
if(myContext != null && receiverRegistered){
17141714
synchronized (MqttAndroidClient.this) {
17151715
LocalBroadcastManager.getInstance(myContext).unregisterReceiver(this);
1716-
registerReceiver = false;
1716+
receiverRegistered = false;
17171717
}
17181718
if(bindedService){
17191719
try{
@@ -1736,7 +1736,7 @@ public void unregisterResources(){
17361736
public void registerResources(Context context){
17371737
if(context != null){
17381738
this.myContext = context;
1739-
if(!registerReceiver){
1739+
if(!receiverRegistered){
17401740
registerReceiver(this);
17411741
}
17421742
}

0 commit comments

Comments
 (0)