Merge pull request #27 from recurly/headers

Added headers to packet

README.md

@@ -122,6 +122,7 @@ starsky.once('connect', function () {
     console.log('body: %j', msg.body);
     console.log('timestamp: %s', msg.timestamp);
     console.log('topic: %s', msg.topic);
+    console.log('headers %s', msg.headers);
     done();
   });
 });
@@ -143,13 +144,15 @@ To start processing message, invoke `consumer.process`. This will invoke the fun
   - `body`: The actual message published.
   - `timestamp`: The time when the message was published.
   - `topic`: The topic the message was published with.
+  - `headers`: The headers associated with the message.
 
 ```js
 consumer.process(function (msg, done) {
   console.log('id: %s', msg.id);
   console.log('body: %j', msg.body);
   console.log('timestamp: %s', msg.timestamp);
   console.log('topic: %s', msg.topic);
+  console.log('headers %s', msg.headers);
   done();
 });
 ```

lib/consumer.js

@@ -160,7 +160,8 @@ Consumer.prototype.onMessage = function (callback) {
       id: info.messageId,
       body: body,
       timestamp: info.timestamp,
-      topic: msg.routingKey
+      topic: msg.routingKey,
+      headers: headers
     };
 
     // keep track of packets in-process, see quit()

test/consumer.test.js

@@ -23,6 +23,7 @@ describe('Consumer', function () {
           msg.should.have.property('timestamp');
           msg.should.have.property('topic', 'foo.bar');
           msg.body.should.have.property('hello', 'world');
+          msg.should.have.property('headers');
           next();
           done();
         });