class ElasticAPM::Transport::Base

def initialize(config)
  @config = config
  @queue = SizedQueue.new(config.api_buffer_size)
  @serializers = Serializers.new(config)
  @filters = Filters.new(config)
  @stopped = Concurrent::AtomicBoolean.new
  @workers = Array.new(config.pool_size)
  @watcher_mutex = Mutex.new
  @worker_mutex = Mutex.new
end