Databases
StackOverflow2013
Postsdbo
POWierd paho.mqttv3 exception
 

Note that there are some explanatory texts on larger screens.

plurals
  1. POWierd paho.mqttv3 exception
    primarykey
    data
    text
    <p>I have written a mqtt client using paho mqttv3 This is the code for the client:</p> <pre><code>public class MQTT_Client { private MqttClient mqtt; private MqttConnectOptions conOpt; private static Logger log = Logger.getRootLogger(); private String topicFilter; private int connectionTimeout = 30; public MQTT_Client(String brokerUrl) { this.topicFilter = "/bmpiips/+/hb/out"; try { String clientId = "HBA"; mqtt = new MqttClient(brokerUrl, clientId, new MemoryPersistence()); log.info("Connecting to " + brokerUrl + " with client ID " + mqtt.getClientId()); conOpt = new MqttConnectOptions(); conOpt.setCleanSession(true); mqtt.setCallback(new MQTT_Callback(this)); } catch (MqttException e) { log.error(null, e); } } public void start() { reconnect(); try { subscribe(topicFilter, 1); } catch (MqttException e) { log.warn("Unable to subscribe to " + topicFilter); } } private void connect() throws MqttSecurityException, MqttException { if (mqtt.isConnected() == false) { mqtt.connect(conOpt); if (mqtt.isConnected() == true) { log.info("Connected to MQTT Broker."); } } } public boolean isConnected() { return mqtt.isConnected(); } public boolean publish(String topicName, byte[] payload, int qos) { try { MqttTopic topic = mqtt.getTopic(topicName); MqttMessage message = new MqttMessage(payload); message.setQos(qos); log.info("Publishing to topic: \"" + topicName + "\" Message size: " + payload.length + " bytes"); MqttDeliveryToken token = topic.publish(message); token.waitForCompletion(); return true; } catch (MqttException e) { log.error(null, e); return false; } } public void subscribe(String topicName, int qos) throws MqttSecurityException, MqttException { mqtt.subscribe(topicName, qos); log.info("Subscribed to topic \"" + topicName + "\""); } public void reconnect() { if (mqtt.isConnected() == false) { try { connect(); } catch (MqttSecurityException e) { log.error("Coud not reconnect...", e); } catch (MqttException e) { log.error("Coud not reconnect...", e); } } else { log.error("Allready connected..."); } } public void disconnect() throws MqttException { mqtt.disconnect(); while (mqtt.isConnected()) { // wait for disconnection } if (mqtt.isConnected() == false) { log.info("Disconnected from the MQTT Broker."); } } public String getTopicFilter() { return topicFilter; } public int getConnectionTimeout() { return connectionTimeout; } } </code></pre> <p>and this is the code for the callback class:</p> <pre><code>public class MQTT_Callback implements MqttCallback { private static Logger log = Logger.getRootLogger(); private static MQTT_ThreadPool threadPool = new MQTT_ThreadPool(); private final MQTT_Client mqtt; public MQTT_Callback(MQTT_Client mqtt) { this.mqtt = mqtt; } @Override public void connectionLost(Throwable cause) { log.error("Disconnected from MqttBroker", cause); while (mqtt.isConnected() == false) { try { log.info("Sleeping for : " + mqtt.getConnectionTimeout() + " seconds..."); Thread.sleep(mqtt.getConnectionTimeout() * 1000); } catch (InterruptedException e) { log.error("Coud not sleep..."); } mqtt.reconnect(); try { mqtt.subscribe(mqtt.getTopicFilter(), 1); } catch (MqttException e) { log.error(e); } } } @Override public void deliveryComplete(MqttDeliveryToken token) { log.info("Message delivered successfully"); } @Override public void messageArrived(MqttTopic topic, MqttMessage message) throws Exception { log.info("Message received from topic: " + topic.getName() + " Message size: " + message.getPayload().length + " bytes"); threadPool.execute(topic, message); } } </code></pre> <p>It works ok but from time to time I get a weird exception that kills the connection:</p> <pre><code>2013-07-09 10:36:05.959 ERROR root:23 - Disconnected from MqttBroker Connection lost (32109) - java.io.EOFException at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:119) at java.lang.Thread.run(Unknown Source) Caused by: java.io.EOFException at java.io.DataInputStream.readByte(Unknown Source) at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:51) at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:86) ... 1 more </code></pre> <p>If anyone has ever come across this please give me some tips.</p>
    singulars
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PTQuestion
    1. UScosmin.danisor
    1. UScosmin.danisor
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. COIs this using the pre-built binary available from Paho? The code in the git repository is much more recent and has a large number of changes - including a small API change. It is probably worth trying the latest code before trying to debug this too far. If it is a bug, you should follow-up on the Paho-dev mailing list.
      singulars
      1. POWierd paho.mqttv3 exception
      1. USknolleary
    2. COI'm using the prebuilt Paho, I will try with the lastest sources and get back here with the result
      singulars
      1. POWierd paho.mqttv3 exception
      1. UScosmin.danisor
    3. COThere's a new prebuilt binary in the Eclipse Maven repository with the latest code.
      singulars
      1. POWierd paho.mqttv3 exception
      1. USAndy Piper
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload