publisher.js

(function(){
	var user_name = "tonsho@github";
	var pass = "pass";
	var wsurl = "ws://lite.mqtt.shiguredo.jp:8080/mqtt";

	var client; // MQTTのクライアントです
	var clientId = "clientid-test"; // ClientIDを指定します。

	$(document).ready(function() {
		var $log = $("#log");
		$log.print = function (message) {
			this.append(message + "<br/>");
		};
		$("#publish-form").submit(function () {
			console.log("connect");
			publish($("#topic").val(), $("#message").val(), $log);
		});
		$("#topic").val(user_name + "/a/b");
	});

	function publish(topic, message, log) {
		if (!client) {
			connect(function() {
				send(topic, message);
			});
			return;
		}
		send(topic, message);

		function connect(callback) {
			// WebSocketURLとClientIDからMQTT Clientを作成します
			client = new Paho.MQTT.Client(wsurl, clientId);

			// connectします
			client.connect({
				userName : user_name,
				password : pass,
				onSuccess : onConnect,
				onFailure : failConnect
			});

			// 接続が失敗したら呼び出されます
			function failConnect(e) {
				log.print("connect failed");
				log.print(e);
				alert(e);
			}

			// 接続に成功したら呼び出されます
			function onConnect() {
				log.print("onConnect");
				callback();
			}
		}

		function send(topic, message) {
			var mqttMessage = new Paho.MQTT.Message(message);
			mqttMessage.destinationName = topic;
			client.send(mqttMessage);
		}
	}
}());