Sha256: a43de6863f02420917213826baedd03469732b41d81b520b74fad4cae03b5516
Contents?: true
Size: 1.28 KB
Versions: 13
Compression:
Stored size: 1.28 KB
Contents
# frozen_string_literal: true
module Msgr
class Message
attr_reader :delivery_info, :metadata, :payload, :route
def initialize(channel, delivery_info, metadata, payload, route)
@channel = channel
@delivery_info = delivery_info
@metadata = metadata
@payload = payload
@route = route
# rubocop:disable Style/GuardClause
if content_type == 'application/json'
@payload = JSON.parse(payload)
@payload.symbolize_keys! if @payload.respond_to? :symbolize_keys!
end
end
def content_type
@metadata.content_type
end
# Check if message is already acknowledged.
#
# @return [Boolean] True if message is acknowledged, false otherwise.
# @api public
#
def acked?
@acked ? true : false
end
# Send message acknowledge to broker unless message is
# already acknowledged.
#
# @api public
#
def ack
return if acked?
@acked = true
@channel.ack delivery_info.delivery_tag
end
# Send negative message acknowledge to broker unless
# message is already acknowledged.
#
# @api public
#
def nack
return if acked?
@acked = true
@channel.nack delivery_info.delivery_tag
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems