lib/cloudwatchlogger/client/aws_sdk/threaded.rb
# Pushes a message to the delivery thread, starting one if necessary
Pushes a message to the delivery thread, starting one if necessary
Pushes a message to the delivery thread starting one if necessary
def deliver(message)
          start_thread unless @thread.alive?
          @thread.deliver(message)
        rescue NoMethodError
          @thread&.kill 
          start_thread
          retry
        end
def deliver ( message ) start_thread unless @thread . alive? @thread . deliver ( message ) rescue NoMethodError @thread &. kill start_thread retry end
Pushes a message to the delivery thread, starting one if necessary
Pushes a message to the delivery thread starting one if necessary
# Race condition? Sometimes we need to rescue this and start a new thread # Try not to leak threads, should already be dead anyway
message
<not_specific>