initialize

in lib/kinesis_producer/daemon.rb [21:46]

• 22 lines of code
• 4 McCabe index (conditional complexity)

    def initialize(binary, handler, options)
      @binary  = binary
      @handler = handler

      @configuration             = options[:configuration] || {}
      @credentials               = options[:credentials]
      @metrics_credentials       = options[:metrics_credentials]
      @credentials_refresh_delay = options[:credentials_refresh_delay] || 5000
      @logger                    = options[:logger]
      @debug                     = options[:debug]

      @executor = Concurrent::CachedThreadPool.new
      @shutdown = Concurrent::AtomicBoolean.new(false)
      @outgoing_messages = Queue.new
      @incoming_messages = Queue.new

      if debug?
        @meters = {
          add_message:     Meter.new,
          send_message:    Meter.new,
          receive_message: Meter.new,
          return_message:  Meter.new,
        }
      end
    end