Continuing to build out tests for the message object.

node/lib/index.js

@@ -1,2 +1,2 @@
 exports.Queue = require('./queue').Queue;
-
+exports.Message = require('./message').Message;

node/lib/message.js

@@ -5,4 +5,14 @@ exports.Message = function(params) {
     var defaults = {
     };
     extend(this, defaults, params);
+};
+
+exports.Message.prototype.toObject = function() {
+    var object = {};
+    for (var key in this) {
+        if (this.hasOwnProperty(key)) {
+            object[key] = this[key];
+        }
+    }
+    return object;
 };

node/test/index.js

@@ -14,10 +14,13 @@ function run(callback, test) {
             callback(
                 function() {
                     puts(test + ' \033[32m[Success]\033[m');
-                    var nextTest = tests.shift();
-                    if (nextTest) {
-                        nextTest();
+                    if (tests.length == 0) {
+                        puts(' \033[32mAll tests finished.\033[m');
+                        process.exit();
                     }
+
+                    var nextTest = tests.shift();
+                    nextTest();
                 },
                 test + ': '
             );

node/test/message_test.js

@@ -1,6 +1,6 @@
-var a = require('assert'),
+var equal = require('assert').equal,
     puts = require('sys').puts,
-    Message = require('../lib').Queue,
+    Message = require('../lib').Message,
     mongodb = require('mongodb'),
     Db = mongodb.Db,
     Connection = mongodb.Connection,
@@ -14,8 +14,33 @@ exports.tests = {
                'bar': 10
             }
         });
-        a.equal(99, message.foo, prefix + 'foo not equal to 99');
-        a.equal(10, message.inner_dictionary.bar, prefix + 'bar not equal to 10');
+        equal(99, message.foo, prefix + 'foo not equal to 99');
+        equal(10, message.inner_dictionary.bar, prefix + 'bar not equal to 10');
+        finished();
+    },
+
+    'should serialize appropriate variables when toObject is called': function(finished, prefix) {
+
+        var object = {
+            'apple': 7,
+            'banana': 5,
+            'inner_dictionary': {
+                'foo': 2,
+                'bar': 4
+            }
+        };
+        var message = new Message(object);
+        var rawMessage = message.toObject();
+
+        var count = 0;
+        for (var key in rawMessage) {
+            if (rawMessage.hasOwnProperty(key)) {
+                count += 1;
+            }
+        }
+
+        equal(2, rawMessage.inner_dictionary.foo, prefix + 'foo had wrong value');
+        equal(3, count, prefix + 'wrong number of keys serialized.');
         finished();
     }
 };