Permalink
Browse files

Added amqp_headers

Still a work in progress
  • Loading branch information...
1 parent d430cb1 commit 31617226dd89772e37099d4a904f01b7e84778ef @ivanvanderbyl committed May 23, 2011
Showing with 2 additions and 2 deletions.
  1. +2 −2 lib/cloudist/payload.rb
@@ -3,7 +3,7 @@ class Payload
include Utils
include Encoding
- attr_reader :body, :headers, :timestamp
+ attr_reader :body, :headers, :amqp_headers, :timestamp
def initialize(body, headers = {})
@published = false
@@ -12,7 +12,7 @@ def initialize(body, headers = {})
body = decode(body) if body.is_a?(String)
@body = Hashie::Mash.new(decode(body))
@headers = Hashie::Mash.new(headers)
-
+ @amqp_headers = {}
# puts "Initialised Payload: #{id}"
parse_headers!

0 comments on commit 3161722

Please sign in to comment.