Contents

# encoding: utf-8
require "logstash/util/loggable"
java_import java.util.function.Consumer

module LogStash
  module Inputs
    module Azure
      class ErrorNotificationHandler
        include Consumer
        include LogStash::Util::Loggable

        def initialize
          @logger = self.logger
        end

        def accept(exception_received_event_args)
          @logger.error("Error with Event Processor Host. ", :exception_received_event_args => exception_received_event_args.to_s)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logstash-input-azure_event_hubs-1.0.0	lib/logstash/inputs/error_notification_handler.rb