Re: [paho-dev] Paho Java: NullPointerException when reconnecting

["James Sutton1" <james.sutton@xxxxxxxxxx>]

Just a quick followup on this:

 

I'd forgotten that in the develop branch, there is already this null check: https://github.com/eclipse/paho.mqtt.java/blob/develop/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttAsyncClient.java#L1216

 

So you should be good to go ahead and use a SNAPSHOT build.

 

Kind regards,

 

James Sutton
Software Engineer - IoT Foundation - MQTT Open Source Projects
Ops Team - Wimbledon Project

Phone: 01962 815438 | Extension: x372454 E-mail: james.sutton@xxxxxxxxxx Personal Website: www.jsutton.co.uk Find me on:	Hursley Park Hursley, SO212JN United Kingdom

 

IBM United Kingdom Limited Registered in England and Wales with number 741598 Registered office: PO Box 41, North Harbour, Portsmouth, Hants. PO6 3AU

 

 

----- Original message -----
From: Yohei Onishi <Onishi_Yohei@xxxxxxxxxxxxx>
Sent by: paho-dev-bounces@xxxxxxxxxxx
To: paho-dev@xxxxxxxxxxx
Cc:
Subject: [paho-dev] Paho Java: NullPointerException when reconnecting
Date: Tue, Nov 29, 2016 2:50 AM
 

Hi All,

I have a basic question about how to use the reconnect method on  
MqttClient and MqttClient. Is the reconnect method on MqttClient and  
MqttClient only for Paho's atumatic connect?

It is not mentioned in the documents, so this was a little bit confusing.

When I call this method in the connectionLost callback (MqttCallback),  
it seems that NullPointerException happens in the  
MqttAsyncClient::stopReconnectCycle.

--- connectionLost callback in my cose
@Override
public void connectionLost(Throwable cause) {
     try {
         sampleClient.reconnect(); // null pointer exception
     } catch (MqttException e) {
         e.printStackTrace();
     }
}
---

NullPointerException is thrown when MqttAsyncClient tries to cancel the  
reconnectTimer because this is initialized only if atumatic connect is  
true. The exception is caught in CommsCallback's connectionLost, so the  
execption does not propagate.

---
private void stopReconnectCycle(){
     String methodName = "stopReconnectCycle";
     //@Trace 504=Stop reconnect timer for client: {0}
     log.fine(CLASS_NAME, methodName, "504", new Object[]{this.clientId});
     reconnectTimer.cancel();
     reconnectDelay = 1000; // Reset Delay Timer
}
---

Thanks,
Yohei

--
Yohei Onishi
OGIS-RI Co.,Ltd.
Tel: 050-3367-1634

_______________________________________________
paho-dev mailing list
paho-dev@xxxxxxxxxxx
To change your delivery options, retrieve your password, or unsubscribe from this list, visit
https://dev.eclipse.org/mailman/listinfo/paho-dev
 

 

Unless stated otherwise above:
IBM United Kingdom Limited - Registered in England and Wales with number 741598. 
Registered office: PO Box 41, North Harbour, Portsmouth, Hampshire PO6 3AU