Contents

module NulogyMessageBusConsumer
  class Config
    attr_accessor :bootstrap_servers,
      :client_id,
      :consumer_group_id,
      :lag_check_interval_seconds,
      :lag_checks,
      :topic_name

    def initialize(options = {})
      defaults = {
        lag_check_interval_seconds: 20,
        lag_checks: 6
      }

      update(defaults.merge(options))
    end

    def update(options = {})
      options.each { |key, value| public_send("#{key}=", value) }
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
nulogy_message_bus_consumer-0.5.0	lib/nulogy_message_bus_consumer/config.rb
nulogy_message_bus_consumer-1.0.0.alpha	lib/nulogy_message_bus_consumer/config.rb
nulogy_message_bus_consumer-0.4.0	lib/nulogy_message_bus_consumer/config.rb