001package var.mom.mqtt.log;
002
003import java.util.Date;
004
005import org.eclipse.paho.client.mqttv3.MqttClient;
006import org.eclipse.paho.client.mqttv3.MqttException;
007import org.eclipse.paho.client.mqttv3.MqttMessage;
008
009/**
010 * client for the log service
011 *
012 * @author Sandro Leuchter
013 *
014 */
015class Publisher {
016
017        /**
018         * main routine and starting point of program
019         *
020         * @param args not used
021         */
022        public static void main(String[] args) {
023                MqttClient client;
024                String clientId = MqttClient.generateClientId();
025                try {
026                        client = new MqttClient(Conf.BROKER, clientId);
027                        client.connect();
028                        MqttMessage message = new MqttMessage();
029                        for (int i = 0; i < 30; i++) {
030                                String m = "[" + clientId + "] message " + i + ": " + (new Date()).toString();
031                                message.setPayload(m.getBytes());
032                                client.publish(Conf.TOPIC, message);
033                        }
034                        client.disconnect();
035                } catch (MqttException e) {
036                        System.err.println(e.getMessage());
037                }
038        }
039}