WAMP - Revision history

Donsez: /* Install Crossbar (the Router) */

2014-11-16T21:20:23Z

Install Crossbar (the Router)

← Older revision		Revision as of 21:20, 16 November 2014
Line 19:		Line 19:
	crossbar start		crossbar start
	</pre>		</pre>

			Open http://localhost:8080/

	===Install Autobahn (The Node.js client)===		===Install Autobahn (The Node.js client)===

Donsez: /* Install Autobahn (The Node.js client) */

2014-11-16T21:19:49Z

Install Autobahn (The Node.js client)

← Older revision		Revision as of 21:19, 16 November 2014
Line 21:		Line 21:

	===Install Autobahn (The Node.js client)===		===Install Autobahn (The Node.js client)===
			* http://crossbar.io/docs/Getting-started-with-NodeJS/
	* http://autobahn.ws/js/gettingstarted.html		* http://autobahn.ws/js/gettingstarted.html
	* http://autobahn.ws/js/programming.html		* http://autobahn.ws/js/programming.html

Donsez: /* Node.js */

2014-11-16T21:19:32Z

Node.js

← Older revision		Revision as of 21:19, 16 November 2014
Line 9:		Line 9:

	==[[Node.js]]==		==[[Node.js]]==
			===Install Crossbar (the Router)===
	* http://crossbar.io/		* http://crossbar.io/

			<pre>
			pip install crossbar[tls,msgpack,manhole,system]
			crossbar version
			crossbar init --template hello:nodejs --appdir hello
			cd hello
			crossbar start
			</pre>

			===Install Autobahn (The Node.js client)===
	* http://autobahn.ws/js/gettingstarted.html		* http://autobahn.ws/js/gettingstarted.html
	* http://autobahn.ws/js/programming.html		* http://autobahn.ws/js/programming.html

	<pre>		<pre>
	npm install autobahn		npm install -g autobahn
			export NODE_PATH=/usr/local/lib/node_modules
	</pre>		</pre>


	<pre>		<pre>
		⚫	var autobahn = require('autobahn');

⚫	var autobahn = require('autobahn')

	var connection = new autobahn.Connection({		var connection = new autobahn.Connection({
	url: 'ws://127.0.0.1:~~9000~~/',		url: 'ws://127.0.0.1:8080/ws',
	realm: 'realm1'		realm: 'realm1'}
	});		);

	connection.onopen = function (session) {		connection.onopen = function (session) {

	// ~~1) subscribe~~ to a topic		// SUBSCRIBE to a topic and receive events
			//
⚫	function ~~onevent~~(~~args~~) {
	~~console.log~~(~~"Event:",~~ args~~[0]~~);		function onhello (args) {
			var msg = args[0];
			console.log("event for 'onhello' received: " + msg);
	}		}
	session.subscribe('com.~~myapp~~.~~hello~~', ~~onevent~~);		session.subscribe('com.example.onhello', onhello).then(
		⚫	function (sub) {
			console.log("subscribed to topic 'onhello'");
			},
		⚫	function (err) {
			console.log("failed to subscribed: " + err);
			}
			);

⚫	// ~~2) publish~~ an event
⚫	session.publish('com.~~myapp~~.~~hello~~', [~~'Hello, world!'~~]);

	// ~~3) register~~ a procedure for ~~remoting~~		// REGISTER a procedure for remote calling
			//
⚫	function ~~add2~~(~~args~~) {
	~~return~~ args~~[0]~~ ~~+ args[1];~~		function add2 (args) {
			var x = args[0];
			var y = args[1];
			console.log("add2() called with " + x + " and " + y);
			return x + y;
	}		}
	session.register('com.~~myapp~~.add2', add2);		session.register('com.example.add2', add2).then(
			function (reg) {

	// 4) ~~call~~ a ~~remote~~ procedure		console.log("procedure add2() registered");
			},
⚫	session.call('com.~~myapp~~.~~add2~~', [2, 3]).then(
	function (~~res~~) {		function (err) {
	console.log("~~Result~~:", ~~res~~);		console.log("failed to register procedure: " + err);
	}		}
	);		);


			// PUBLISH and CALL every second .. forever
			//
			var counter = 0;
			setInterval(function () {

		⚫	// PUBLISH an event
			//
		⚫	session.publish('com.example.oncounter', [counter]);
			console.log("published to 'oncounter' with counter " + counter);

			// CALL a remote procedure
			//
		⚫	session.call('com.example.mul2', [counter, 3]).then(
			function (res) {
			console.log("mul2() called with result: " + res);
			},
			function (err) {
			if (err.error !== 'wamp.error.no_such_procedure') {
			console.log('call of mul2() failed: ' + err);
			}
			}
			);

			counter += 1;
			}, 1000);
	};		};

	connection.open();		connection.open();

	</pre>		</pre>

Donsez: /* Node.js */

2014-11-16T21:12:55Z

Node.js

← Older revision		Revision as of 21:12, 16 November 2014
Line 9:		Line 9:

	==[[Node.js]]==		==[[Node.js]]==
	http://~~autobahn~~.ws/~~js/gettingstarted.html~~		* http://crossbar.io/

⚫	http://autobahn.ws/js/programming.html
			* http://autobahn.ws/js/gettingstarted.html
		⚫	* http://autobahn.ws/js/programming.html

	<pre>		<pre>

Donsez: /* Node.js */

2014-11-16T21:11:13Z

Node.js

← Older revision		Revision as of 21:11, 16 November 2014
Line 10:		Line 10:
	==[[Node.js]]==		==[[Node.js]]==
	http://autobahn.ws/js/gettingstarted.html		http://autobahn.ws/js/gettingstarted.html
			http://autobahn.ws/js/programming.html

	<pre>		<pre>

Donsez: /* Node.js */

2014-11-16T21:10:04Z

Node.js

← Older revision		Revision as of 21:10, 16 November 2014
Line 9:		Line 9:

	==[[Node.js]]==		==[[Node.js]]==
			http://autobahn.ws/js/gettingstarted.html

	<pre>		<pre>
			npm install autobahn
			</pre>


			<pre>

			var autobahn = require('autobahn')

	var connection = new autobahn.Connection({		var connection = new autobahn.Connection({
	url: 'ws://127.0.0.1:9000/',		url: 'ws://127.0.0.1:9000/',

Donsez: /* Node.js */

2014-11-16T21:07:38Z

Node.js

← Older revision		Revision as of 21:07, 16 November 2014
Line 43:		Line 43:
	connection.open();		connection.open();
	</pre>		</pre>

			==[[Node-RED]]==
			TODO

Donsez: /* Extra */

2014-11-16T21:07:15Z

Extra

← Older revision		Revision as of 21:07, 16 November 2014
Line 7:		Line 7:
	==Extra==		==Extra==
	* WAMP with Arduino Yun http://tavendo.com/blog/post/arduino-yun-with-autobahn/		* WAMP with Arduino Yun http://tavendo.com/blog/post/arduino-yun-with-autobahn/

			==[[Node.js]]==

			<pre>
			var connection = new autobahn.Connection({
			url: 'ws://127.0.0.1:9000/',
			realm: 'realm1'
			});

			connection.onopen = function (session) {

			// 1) subscribe to a topic
			function onevent(args) {
			console.log("Event:", args[0]);
			}
			session.subscribe('com.myapp.hello', onevent);

			// 2) publish an event
			session.publish('com.myapp.hello', ['Hello, world!']);

			// 3) register a procedure for remoting
			function add2(args) {
			return args[0] + args[1];
			}
			session.register('com.myapp.add2', add2);

			// 4) call a remote procedure
			session.call('com.myapp.add2', [2, 3]).then(
			function (res) {
			console.log("Result:", res);
			}
			);
			};

			connection.open();
			</pre>

Donsez: Created page with "WAMP (Web Application Messaging Protocol) is an open WebSocket subprotocol that provides two application messaging patterns in one unified protocol: [[Remote Procedure Cal..."

2014-05-16T04:05:56Z

Created page with "WAMP (Web Application Messaging Protocol) is an open WebSocket subprotocol that provides two application messaging patterns in one unified protocol: [[Remote Procedure Cal..."

New page

WAMP (Web Application Messaging Protocol) is an open [[WebSocket]] subprotocol that provides two application messaging patterns in one unified protocol: [[Remote Procedure Call]]s + [[Publish-Subscribe]]

* http://wamp.ws/spec/
* https://github.com/tavendo/WAMP/blob/master/spec/basic.md
* https://github.com/tavendo/WAMP/blob/master/spec/advanced.md

==Extra==
* WAMP with Arduino Yun http://tavendo.com/blog/post/arduino-yun-with-autobahn/