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