12345678910111213141516171819202122232425262728 |
- importScripts ("/stomp.js");
- // *WebWorker* onmessage implementation
- onmessage = function (event) {
- var url = event.data.url;
- var login = event.data.login;
- var passcode = event.data.passcode;
- var destination = event.data.destination;
- var text = event.data.text;
- // create the Stomp client
- var client = Stomp.client(url);
-
- // connect to the server
- client.connect(login, passcode, function(frame) {
- // upon connection, subscribe to the destination
- var sub = client.subscribe(destination, function(message) {
- // when a message is received, post it to the current WebWorker
- postMessage("WebWorker: " + message.body);
- //... unsubscribe from the destination
- sub.unsubscribe();
- //... and disconnect from the server
- client.disconnect();
- });
- // send the text to the destination
- client.send(destination, {}, text);
- });
- };
|