need to save this, dying harddrive

Author: benjaminws

lib/frame.js

@@ -73,12 +73,17 @@ Frame.prototype.send_frame = function(frame) {
     self = this;
     this.sock.write(frame.as_string());
 
-    if ('receipt' in frame.headers)
+    if ('receipt' in frame.headers) {
+        console.log('receipt in headers');
         return this.get_reply();
+    }
 
 };
 
 Frame.prototype.parse_frame = function(data) {
+
+    console.log("RAW DATA AT PARSE_FRAME: " + data);
+
     var self = this,
         args = {},
         headers_str = null;

lib/stomp.js

@@ -24,16 +24,16 @@ Stomp.prototype.connect = function(headers) {
     this.stomp_log.debug('Connecting to ' + this.host + ':' + this.port);
     socket = net.createConnection(this.port, this.host);
     socket.setEncoding('ascii');
-    socket.setTimeout(0);
+//    socket.setTimeout(0);
     socket.setNoDelay(true);
 
     socket.addListener('connect', function() {
         self.stomp_log.debug('Connected to socket');
         self.connected_frame = self.frame_object.stomp_connect(self.socket);
     });
 
-    socket.addListener('drain', function() {
-
+    socket.addListener('drain', function(data) {
+        console.log("DRAIN_DATA: " + data);
     });
 
     socket.addListener('data', function(data) {
@@ -110,19 +110,19 @@ Stomp.prototype.ack = function(message_id) {
 };
 
 Stomp.prototype.send = function(headers) {
-
+    extra = {};
     destination = headers['destination'];
     body = headers['body'] || null;
-    headers['want_receipt'] = true;
-
+    extra['want_receipt'] = true;
     return this._send_command('SEND', headers, body)
 };
 
-Stomp.prototype._send_command = function(command, headers, body) {
+Stomp.prototype._send_command = function(command, headers, body, the_rest) {
 
     if (!this.utils.really_defined(headers))
         headers = {};
 
+    console.log("HEADERS: " + sys.inspect(headers));
     frame_conf = {
         'command': command,
         'headers': headers,
@@ -132,8 +132,10 @@ Stomp.prototype._send_command = function(command, headers, body) {
     var this_frame = this.connected_frame.build_frame(frame_conf);
     var reply = this.connected_frame.send_frame(this_frame);
 
-    if ('want_receipt' in headers)
+    if ('want_receipt' in the_rest) {
+        console.log('want_receipt = true');
         return reply;
+    }
 
     return this_frame;