MQTT Publisher

MQTTPublisher.java

    /*
     * Publisher method: publishing data over MQTT broker (RABBIT_MQ)
     */

    public void publishMessage() {
        publishThreadMQTT = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    if (mqttAndroidClient != null) {
                        MqttMessage message = new MqttMessage(queue.takeFirst().getBytes());
                        if (message != null) {
                            mqttAndroidClient.publish(topic, message);
                            onConnection.onPublish();

                        }
                    }
                } catch (MqttException e) {
                    onConnection.onPublishFail();
                    System.err.println("Error Publishing: " + e.getMessage());
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    onConnection.onPublishFail();
                    e.printStackTrace();
                }
            }
        });
        publishThreadMQTT.start();

    }