expose seq in messages

jhs · Apr 21, 2014 · f7569bc · f7569bc
1 parent 1452947
commit f7569bc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/message.js b/message.js
@@ -45,6 +45,7 @@ function Message (opts) {
   self.IdExtra     = opts.IdExtra     || null;
   self.queue       = opts.queue       || null;
   self.is_heartbeat= opts.is_heartbeat|| false;
+  self.seq         = opts.seq         || null;
 
   self.log = debug('cqs:message:' + (self.MessageId || 'untitled'));
 }

diff --git a/queue.js b/queue.js
@@ -306,6 +306,7 @@ Queue.prototype.changes = function(opts) {
 
     var msg_opts = {}
     lib.copy(change.doc, msg_opts, 'uppercase')
+    msg_opts.seq = change.seq;
     msg_opts.MessageId = change.id.substr(prefix.length)
 
     var msg = new message.Message(msg_opts)