lib/fluent/plugin/out_amqp.rb
# This method is called when starting.
# Open sockets or files here.
This method is called when starting.
Open sockets or files here.
This method is called when starting . Open sockets or files here .
def start
    super
    begin
      get_or_create_exchange
    rescue => e
      $log.error "AMQP error", error: e.to_s
      $log.warn_backtrace e.backtrace
    end
  end
def start super begin get_or_create_exchange rescue => e $log . error "AMQP error" , error : e . to_s $log . warn_backtrace e . backtrace end end
This method is called when starting.
This method is called when starting .