Sha256: fc8b0b1cc70d0c3485e55a44be959ff478e599badfa6425fab221f62db3a9e6f
Contents?: true
Size: 567 Bytes
Versions: 7
Compression:
Stored size: 567 Bytes
Contents
module Msgr
require 'msgr/message/acknowledge'
class Message
include Acknowledge
attr_reader :delivery_info, :metadata, :payload, :route
def initialize(connection, delivery_info, metadata, payload, route)
@connection = connection
@delivery_info = delivery_info
@metadata = metadata
@payload = payload
@route = route
if content_type == 'application/json'
@payload = JSON[payload].symbolize_keys
end
end
def content_type
@metadata.content_type
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems