subscriber.js

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

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

	function startSubscribe(topic, log) {
		var client; // MQTTのクライアントです
		var clientId = "clientid-test"; // ClientIDを指定します。
		connect();

		function connect() {
			// 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);
		}

		// 接続に成功したら呼び出されます
		function onConnect() {
			log.print("onConnect");
			subscribe();
		}
		// メッセージが到着したら呼び出されるコールバック関数
		function onMessageArrived(message) {
			log.print("onMessageArrived:" + message.payloadString);
		}

		function subscribe() {
			// コールバック関数を登録します
			client.onMessageArrived = onMessageArrived;

			// Subscribeします
			client.subscribe(topic);
		}
	}
}());