Kamaloka: AMQP implementation in JS

<>p>Would you like to talk messaging directly from the browser? Kamaloka is a new library that speaks AMQP. You can easily tie to Orbited but also, in theory, any other library that speaks TCPSockets.

Orbited.settings.port = 9000;
amqp_broker_port = 7000;
amqp_conn = amqp.Connection({host: 'localhost',
port: amqp_broker_port,
send_hook: function(msg) { // for debugging
append_msg('SENT', msg);
},
recive_hook: function(data) { // for debugging
append_msg('RECV', data);
}
});
amqp_conn.start();
// You should have your server generate a UUID since browser methods
// are unreliable at best
session = amqp_conn.create_session('not_a_great_id' + (new Date().getTime() + Math.random()));
var fedoraproject = "org.fedoraproject-" + session.name;
session.Queue('declare', {queue:fedoraproject, exclusive:true});
session.Exchange('bind', {exchange: "amq.topic",
queue: fedoraproject,
binding_key: "org.fedoraproject.#"});
// Bind each queue to the control queue so we know when to stop
session.Exchange('bind', {exchange:"amq.topic",
queue: fedoraproject,
binding_key:"control"});

Posted by Dion Almaer at 6:28 am
2 Comments

2.9 rating from 19 votes

2 Comments »

Comments feed TrackBack URI

xmlsockets, wow.
Comment by Darkimmortal — September 8, 2009

Ajax Questions and Answers

Usability Systems
While I've kind of put a hold on the monitoring solution (kind of shifted gears, so twiddling between that and another project), one thing is true...

Goodbye to three-tier computing?
Software in the original mainframe days was all glommed together. Why not? Who was looking? Sometimes, reluctantly, some structure came about. Even in...

Node.js: Bubbling up from JavaScript
Jack Vaughan, Site Editor Bubbling under the mainstream of computing these days is the fast growing phenomenon of Node.js – a framework built on...