class ElasticAPM::Transport::Worker

def initialize(
  config,
  queue,
  serializers:,
  filters:,
  conn_adapter: Connection
)
  @config = config
  @queue = queue
  @serializers = serializers
  @filters = filters
  @connection = conn_adapter.new(config)
end