lib/cloudist/request.rb in cloudist-0.4.4 vs lib/cloudist/request.rb in cloudist-0.5.0
- old
+ new
@@ -1,34 +1,34 @@
module Cloudist
class Request
include Cloudist::Encoding
-
+
attr_reader :queue_header, :qobj, :payload, :start, :headers, :body
def initialize(queue, encoded_body, queue_header)
@qobj, @queue_header = queue, queue_header
@body = decode(encoded_body)
@headers = parse_custom_headers(queue_header)
-
+
@payload = Cloudist::Payload.new(encoded_body, queue_header.headers.dup)
@headers = @payload.headers
@start = Time.now.utc.to_f
end
-
+
def parse_custom_headers(amqp_headers)
h = amqp_headers.headers.dup
h[:published_on] = h[:published_on].to_i
h[:ttl] = h[:ttl].to_i rescue -1
h[:ttl] = -1 if h[:ttl] == 0
h
end
-
+
def for_message
[body.dup, queue_header.headers.dup]
end
def q
@@ -40,10 +40,10 @@
end
def mq
qobj.channel
end
-
+
def channel
mq
end
def age