Contents

# frozen_string_literal: true

require "forwardable"

module Racecar
  class Message
    extend Forwardable

    attr_reader :retries_count

    def initialize(rdkafka_message, retries_count: nil)
      @rdkafka_message = rdkafka_message
      @retries_count   = retries_count
    end

    def_delegators :@rdkafka_message, :topic, :partition, :offset, :key, :headers

    def value
      @rdkafka_message.payload
    end

    def create_time
      @rdkafka_message.timestamp
    end

    def ==(other)
      @rdkafka_message == other.instance_variable_get(:@rdkafka_message)
    end
  end
end

Version data entries

25 entries across 25 versions & 1 rubygems

Version	Path
racecar-2.4.0	lib/racecar/message.rb
racecar-2.3.1	lib/racecar/message.rb
racecar-2.3.0	lib/racecar/message.rb
racecar-2.3.0.alpha1	lib/racecar/message.rb
racecar-2.2.0	lib/racecar/message.rb