30 lines
594 B
JavaScript
30 lines
594 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 received = 0;
|
|
|
|
function onevent1(args) {
|
|
console.log("Got event:", args[0]);
|
|
received += 1;
|
|
if (received > 5) {
|
|
console.log("Closing ..");
|
|
connection.close();
|
|
}
|
|
}
|
|
|
|
session.subscribe('com.myapp.topic1', onevent1);
|
|
};
|
|
|
|
connection.open();
|