Module: Consumer::PositionStore::Put

Defined in:
lib/consumer/position_store.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.prepended(cls) ⇒ Object 



41
42
43
 
# File 'lib/consumer/position_store.rb', line 41

def self.prepended(cls)
  Virtual::Method.define cls, :put
end

Instance Method Details

#put(position) ⇒ Object 



45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/consumer/position_store.rb', line 45

def put(position)
  logger.trace { "Put position (Stream: #{stream.name}, Position: #{position})" }

  super

  logger.debug { "Put position done (Stream: #{stream.name}, Position: #{position})" }

  telemetry.record :put, Telemetry::Put.new(position, stream)

  nil
end