Well, it kinda works. Calling it a night.

Author: benjaminws

lib/frame.js

@@ -2,27 +2,30 @@ var sys = require('sys'),
     utils = require('./stomp-utils'),
     exceptions = require('./stomp-exceptions');
 
-
 Frame = module.exports = function(logger) {
-    this.connected = false;
     this.sock = null;
     this.command = null;
     this.headers = null;
     this.body = null;
+    this.session = null;
     this.stomp_log = logger;
+    this.rqueue = new StompQueue();
+    this.iqueue = new IntermediateQueue();
 };
 
 Frame.prototype.stomp_connect = function(client) {
     this.sock = client;
     var args = {};
     var headers = {};
+    var next_frame = null;
 
     args['command'] = 'CONNECT';
     args['headers'] = headers;
     frame_to_send = this.build_frame(args);
     this.send_frame(frame_to_send);
     this.stomp_log.debug('Connected to STOMP');
-    this.connected = true;
+    next_frame = this.get_reply();
+    this.session = next_frame.headers;
     return this;
 };
 
@@ -61,15 +64,18 @@ Frame.prototype.as_string = function() {
 Frame.prototype.send_frame = function(frame) {
     this.sock.write(frame.as_string());
 
-    if ('receipt' in frame.headers) {
+    if ('receipt' in frame.headers)
         return this.get_reply();
-    }
+
 };
 
 Frame.prototype.parse_frame = function(data) {
     var args = [],
         headers_str = null;
 
+    if (data == null || data == undefined)
+        return;
+
     this.command = this.parse_command(data);
     var _data = data.slice(this.command.length + 1, data.length);
     _data = _data.toString('utf8', start=0, end=_data.length);
@@ -114,7 +120,38 @@ Frame.prototype.parse_headers = function(headers_str) {
 
 Frame.prototype.parse_command = function(data) {
     var command,
-        this_string = data.toString('ascii', start=0, end=data.length);
+        this_string = data.toString('utf8', start=0, end=data.length);
     command = this_string.split('\n');
     return command[0];
 };
+
+Frame.prototype.get_reply = function() {
+    while (true) {
+        try {
+            return this.rqueue.get()
+        }
+        catch (error) {
+            if (error.name == "QueueEmpty") {
+                frame = this.parse_frame();
+                if (frame == null || frame == undefined)
+                    return null;
+                if (frame.command == "MESSAGE")
+                    this.iqueue.put(frame);
+                else
+                    this.rqueue.put(frame);
+            }
+        }
+    }
+};
+
+Frame.prototype.get_message = function() {
+    while (true) {
+        frame = this.rqueue.get()
+        if (frame == null || frame == undefined)
+            return null;
+        if (frame.command == "MESSAGE")
+            return frame;
+        else
+           this.rqueue.put(frame);
+    }
+};

lib/stomp-exceptions.js

@@ -1,8 +1,17 @@
 BrokerErrorResponse = exports.BrokerErrorResponse = function(value) {
-
     this.value = value;
-    this.message = "Broker returned error: " + this.value
-    console.error(this.message + this.value);
+    this.message = "Broker returned error: " + this.value;
+};
 
+BrokerErrorResponse.prototype.toString = function() {
+    return this.messge + this.value;
 };
 
+QueueEmpty = exports.QueueEmpty = function() {
+    this.name = "QueueEmpty";
+    this.message = "Queue is Empty";
+};
+
+QueueEmpty.prototype.toString = function() {
+    return this.message;
+};

lib/stomp-utils.js

@@ -1,3 +1,5 @@
+var exceptions = require('./stomp-exceptions');
+
 StompLogging = exports.StompLogging = function(should_debug) {
     this.should_debug = should_debug;
 };
@@ -37,9 +39,14 @@ StompQueue.prototype.get = function() {
 
         if (++this.queue_space * 2 >= this.queue.length) {
             this.queue = this.queue.slice(this.queue_space);
+            console.log(this.queue);
             this.queue_space = 0;
         }
     }
+
+    if (item == undefined)
+        throw new QueueEmpty();
+
     return item;
 };
 
@@ -48,6 +55,29 @@ StompQueue.prototype.get_oldest_item = function() {
 
     if (this.queue.length)
         item = this.queue[this.queue_space];
+    else
+        throw new QueueEmpty();
 
     return item;
 };
+
+IntermediateQueue = exports.IntermediateQueue = function() {
+    this._queue = new StompQueue();
+};
+
+IntermediateQueue.prototype.put = function(frame) {
+    if (!"destination" in frame.headers)
+        return;
+    this._queue.put(frame);
+}
+
+IntermediateQueue.prototype.get = function(frame) {
+    try {
+        this._queue.get();
+    }
+    catch (error) {
+        if (error.name == "QueueName") {
+            return frame.parse_frame();
+        }
+    }
+}

lib/stomp.js

@@ -29,7 +29,7 @@ Stomp.prototype.connect = function() {
         _stomp.stomp_log.debug('goodbye');
     });
     client.addListener('error', function (error) {
-        console.log('error: ' + error);
+        console.log('error: ' + error.stack);
     });
     client.addListener('close', function (error) {
         _stomp.stomp_log.debug('disconnected');