Added support for message type header

ivanvanderbyl · May 23, 2011 · 767aacf · 767aacf
1 parent e9f19a2
commit 767aacf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/cloudist/payload.rb b/lib/cloudist/payload.rb
@@ -36,6 +36,8 @@ def to_a
 
     def parse_headers!
       headers[:published_on] ||= body.delete("timestamp") || timestamp
+      headers[:message_type] ||= body.delete("message_type") || 'reply'
+
       headers[:ttl] ||= Cloudist::DEFAULT_TTL
       headers[:message_id] = id