Sha256: adefac0a6c2df06d6f583fc9ef5e2c0ee812295c286492f1a92daa8f3cb87871
Contents?: true
Size: 594 Bytes
Versions: 25
Compression:
Stored size: 594 Bytes
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