25 lines
533 B
JavaScript
25 lines
533 B
JavaScript
try {
|
|
var autobahn = require('autobahn');
|
|
} catch (e) {
|
|
// when running in browser, AutobahnJS will
|
|
// be included without a module system
|
|
}
|
|
|
|
var connection = new autobahn.Connection({
|
|
url: 'ws://127.0.0.1:8080/ws',
|
|
realm: 'crossbardemo'}
|
|
);
|
|
|
|
connection.onopen = function (session) {
|
|
|
|
var counter = 0;
|
|
|
|
setInterval(function () {
|
|
console.log("publishing to topic 'com.myapp.topic1': " + counter);
|
|
session.publish('com.myapp.topic1', [counter]);
|
|
counter += 1;
|
|
}, 1000);
|
|
};
|
|
|
|
connection.open();
|