Module: Consumer::Configure

Included in:
HandlerRegistry
Defined in:
lib/consumer/consumer.rb

Instance Method Summary collapse

Instance Method Details

#configure(**kwargs) ⇒ Object 



164
165
166
167
168
169
170
171
172
173
174
 
# File 'lib/consumer/consumer.rb', line 164

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

  super(**kwargs)

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

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