lib/cloudist/request.rb in cloudist-0.0.2 vs lib/cloudist/request.rb in cloudist-0.0.3
- old
+ new
@@ -3,12 +3,12 @@
attr_reader :queue_header, :qobj, :payload, :start, :headers
def initialize(queue, json_encoded_message, queue_header)
@qobj, @queue_header = queue, queue_header
- @payload = Cloudist::Payload.new(json_encoded_message.dup, queue_header.properties.dup)
+ @payload = Cloudist::Payload.new(json_encoded_message.dup, queue_header.headers.dup)
@headers = @payload.parse_custom_headers
-
+
@start = Time.now.utc.to_i
end
def q
qobj.q