class Racecar::Message

Attributes

retries_count[R]

Public Class Methods

new(rdkafka_message, retries_count: nil) click to toggle source
# File lib/racecar/message.rb, line 11
def initialize(rdkafka_message, retries_count: nil)
  @rdkafka_message = rdkafka_message
  @retries_count   = retries_count
end

Public Instance Methods

==(other) click to toggle source
# File lib/racecar/message.rb, line 26
def ==(other)
  @rdkafka_message == other.instance_variable_get(:@rdkafka_message)
end
create_time() click to toggle source
# File lib/racecar/message.rb, line 22
def create_time
  @rdkafka_message.timestamp
end
value() click to toggle source
# File lib/racecar/message.rb, line 18
def value
  @rdkafka_message.payload
end