class ElasticAPM::TimedWorker

def collect_and_send_transactions
  return if pending_transactions.empty?
  transactions = collect_batched_transactions
  payload = @serializers.transactions.build_all(transactions)
  begin
    @adapter.post('/v1/transactions', payload)
  rescue ::Exception => e
    fatal 'Failed posting: %s', e.inspect
    debug e.backtrace.join("\n")
    nil
  end
  @last_sent_transactions = Time.now
end