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}