Method: Observability::Sender#start

Defined in:
lib/observability/sender.rb

#start ⇒ Object

Start sending queued events.



68
69
70
71
72
 
# File 'lib/observability/sender.rb', line 68

def start
  self.log.debug "Starting a %p" % [ self.class ]
  @executor = Concurrent::SingleThreadExecutor.new( fallback_policy: :abort )
  @executor.auto_terminate = true
end