Module: Consumer::Configure

Included in:

HandlerRegistry

Defined in:

lib/consumer/consumer.rb

Instance Method Summary

• #configure(**kwargs) ⇒ Object

Instance Method Details

#configure(**kwargs) ⇒ Object

# File 'lib/consumer/consumer.rb', line 158

def configure(**kwargs)
  logger.trace(tag: :consumer) { "Configuring (Category: #{category})" }

  super(**kwargs)

  starting_position = self.position_store.get

  Subscription.configure(
    self,
    get,
    position: starting_position,
    poll_interval_milliseconds: poll_interval_milliseconds
  )

  logger.debug(tag: :consumer) { "Done configuring (Category: #{category}, Starting Position: #{starting_position})" }
end