Sha256: a02d0d1328d91b03c97673ef2ea4b22a51d145285c03ec861f6017b631999f33
Contents?: true
Size: 1.04 KB
Versions: 17
Compression:
Stored size: 1.04 KB
Contents
module Spacebunny module LiveStream class Message attr_reader :live_stream, :sender_id, :channel_name, :delivery_info, :metadata, :payload def initialize(live_stream, options, delivery_info, metadata, payload) @live_stream = live_stream @options = options @delivery_info = delivery_info @metadata = metadata @payload = payload set_sender_id_and_channel end def ack(options = {}) multiple = options.fetch :multiple, false @live_stream.acknowledge @delivery_info.delivery_tag, multiple end def nack(options = {}) multiple = options.fetch :multiple, false requeue = options.fetch :requeue, false @live_stream.nack @delivery_info.delivery_tag, multiple, requeue end def from_api? !@metadata[:headers].nil? && @metadata[:headers]['x-from-sb-api'] end private def set_sender_id_and_channel @sender_id, @channel_name = @delivery_info[:routing_key].split('.') end end end end
Version data entries
17 entries across 17 versions & 1 rubygems