openstack/deb-python-autobahn
Code Issues Proposed changes

fix demos

Browse Source
This commit is contained in:
Tobias Oberstein
2014-03-04 16:58:06 +01:00
parent ed064bec87
commit 4b09c4fe28
10 changed files with 59 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/twisted/wamp/basic/pubsub/complex/backend.js
View File

@@ -25,6 +25,8 @@ connection.onopen = function (session) {
session.publish('com.myapp.topic2', [randint(0, 100), 23], {c: "Hello", d: obj}); session.publish('com.myapp.topic2', [randint(0, 100), 23], {c: "Hello", d: obj});
counter += 1; counter += 1;
console.log("events published");
}, 1000); }, 1000);
}; };

4
examples/twisted/wamp/basic/pubsub/complex/frontend.js
View File

@@ -16,14 +16,14 @@ connection.onopen = function (session) {
console.log("Got heartbeat (publication ID " + details.publication + ")"); console.log("Got heartbeat (publication ID " + details.publication + ")");
} }
session.subscribe(on_heartbeat, 'com.myapp.heartbeat'); session.subscribe('com.myapp.heartbeat', on_heartbeat);
function on_topic2(args, kwargs) { function on_topic2(args, kwargs) {
console.log("Got event:", args, kwargs); console.log("Got event:", args, kwargs);
} }
session.subscribe(on_topic2, 'com.myapp.topic2'); session.subscribe('com.myapp.topic2', on_topic2);
setTimeout(function () { setTimeout(function () {

2
examples/twisted/wamp/basic/pubsub/options/frontend.js
View File

@@ -27,7 +27,7 @@ connection.onopen = function (session) {
} }
} }
session.subscribe(on_event, 'com.myapp.topic1'); session.subscribe('com.myapp.topic1', on_event);
}; };
connection.open(); connection.open();

1
examples/twisted/wamp/basic/pubsub/unsubscribe/backend.js
View File

@@ -17,6 +17,7 @@ connection.onopen = function (session) {
setInterval(function () { setInterval(function () {
session.publish('com.myapp.topic1', [counter]); session.publish('com.myapp.topic1', [counter]);
counter += 1; counter += 1;
console.log("events published");
}, 1000); }, 1000);
}; };

2
examples/twisted/wamp/basic/pubsub/unsubscribe/frontend.js
View File

@@ -35,7 +35,7 @@ connection.onopen = function (session) {
} }
} }
session.subscribe(on_event, 'com.myapp.topic1').then( session.subscribe('com.myapp.topic1', on_event).then(
function (subscription) { function (subscription) {
sub = subscription; sub = subscription;
console.log("Subscribed with subscription ID " + subscription.id); console.log("Subscribed with subscription ID " + subscription.id);

24
examples/twisted/wamp/basic/rpc/arguments/backend.js
View File

@@ -1,8 +1,10 @@
try { try {
var autobahn = require('autobahn'); var autobahn = require('autobahn');
var when = require('when');
} catch (e) { } catch (e) {
// when running in browser, AutobahnJS will // When running in browser, AutobahnJS will
// be included without a module system // be included without a module system
var when = autobahn.when;
} }
var connection = new autobahn.Connection({ var connection = new autobahn.Connection({
@@ -41,11 +43,21 @@ connection.onopen = function (session) {
return [args.length, Object.keys(kwargs).length]; return [args.length, Object.keys(kwargs).length];
} }
session.register('com.arguments.ping', ping) var dl = [];
session.register('com.arguments.add2', add2)
session.register('com.arguments.stars', stars) dl.push(session.register('com.arguments.ping', ping));
session.register('com.arguments.orders', orders) dl.push(session.register('com.arguments.add2', add2));
session.register('com.arguments.arglen', arglen) dl.push(session.register('com.arguments.stars', stars));
dl.push(session.register('com.arguments.orders', orders));
dl.push(session.register('com.arguments.arglen', arglen));
when.all(dl).then(
function () {
console.log("All registered.");
},
function () {
console.log("Registration failed!", arguments);
});
}; };
connection.open(); connection.open();

9
examples/twisted/wamp/basic/rpc/errors/backend.js
View File

@@ -25,7 +25,14 @@ connection.onopen = function (session) {
return res; return res;
} }
session.register('com.myapp.sqrt', sqrt); session.register('com.myapp.sqrt', sqrt).then(
function (registration) {
console.log("Procedure registered:", registration.id);
},
function (error) {
console.log("Registration failed:", error);
}
);
}; };
connection.open(); connection.open();

15
examples/twisted/wamp/basic/rpc/options/frontend.js
View File

@@ -18,7 +18,7 @@ connection.onopen = function (session) {
console.log("Someone requested to square non-negative:", val); console.log("Someone requested to square non-negative:", val);
} }
session.subscribe(on_event, 'com.myapp.square_on_nonpositive'); session.subscribe('com.myapp.square_on_nonpositive', on_event);
var dl = []; var dl = [];
@@ -35,10 +35,15 @@ connection.onopen = function (session) {
)); ));
} }
when.all(dl).then(function () { when.all(dl).then(
console.log("All finished."); function () {
connection.close(); console.log("All finished.");
}); connection.close();
},
function () {
console.log("Error", arguments);
connection.close();
});
}; };
connection.open(); connection.open();

9
examples/twisted/wamp/basic/rpc/progress/backend.js
View File

@@ -42,7 +42,14 @@ connection.onopen = function (session) {
return d.promise; return d.promise;
} }
session.register('com.myapp.longop', longop); session.register('com.myapp.longop', longop).then(
function (registration) {
console.log("Procedure registered:", registration.id);
},
function (error) {
console.log("Registration failed:", error);
}
);
}; };
connection.open(); connection.open();

9
examples/twisted/wamp/basic/rpc/slowsquare/backend.js
View File

@@ -39,7 +39,14 @@ connection.onopen = function (session) {
return d.promise; return d.promise;
} }
session.register('com.math.slowsquare', slowsquare); session.register('com.math.slowsquare', slowsquare).then(
function (registration) {
console.log("Procedure registered:", registration.id);
},
function (error) {
console.log("Registration failed:", error);
}
);
}; };
connection.open(); connection.open();