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