Last active
January 6, 2021 12:32
-
-
Save benedekh/923823d29bea1f5c2d0c to your computer and use it in GitHub Desktop.
MQTT Synchronous Publisher Client Sample based on https://www.eclipse.org/paho/clients/java/
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package mqtt.demo; | |
import org.eclipse.paho.client.mqttv3.MqttClient; | |
import org.eclipse.paho.client.mqttv3.MqttConnectOptions; | |
import org.eclipse.paho.client.mqttv3.MqttException; | |
import org.eclipse.paho.client.mqttv3.MqttMessage; | |
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence; | |
public class MqttPublishSample { | |
public static void main(String[] args) { | |
String topic = "MQTT Examples"; | |
String content = "Message from MqttPublishSample"; | |
int qos = 2; | |
String broker = "tcp://localhost:1883"; | |
String clientId = "JavaSample"; | |
MemoryPersistence persistence = new MemoryPersistence(); | |
try { | |
MqttClient sampleClient = new MqttClient(broker, clientId, persistence); | |
MqttConnectOptions connOpts = new MqttConnectOptions(); | |
connOpts.setCleanSession(true); | |
System.out.println("Connecting to broker: " + broker); | |
sampleClient.connect(connOpts); | |
System.out.println("Connected"); | |
System.out.println("Publishing message: " + content); | |
MqttMessage message = new MqttMessage(content.getBytes()); | |
message.setQos(qos); | |
sampleClient.publish(topic, message); | |
System.out.println("Message published"); | |
sampleClient.disconnect(); | |
System.out.println("Disconnected"); | |
System.exit(0); | |
} catch (MqttException me) { | |
System.out.println("reason " + me.getReasonCode()); | |
System.out.println("msg " + me.getMessage()); | |
System.out.println("loc " + me.getLocalizedMessage()); | |
System.out.println("cause " + me.getCause()); | |
System.out.println("excep " + me); | |
me.printStackTrace(); | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment