MQTTClient.java

    private void publishMessage(String message) {
        String publishTopic = "outbox";
        MqttMessage msg = new MqttMessage();
        msg.setPayload(message.getBytes());
        try {
            client.publish(publishTopic, msg);
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }