Contents

# encoding: utf-8
require "logstash/inputs/processor"
module LogStash
  module Inputs
    module Azure
      class ProcessorFactory
        include com.microsoft.azure.eventprocessorhost.IEventProcessorFactory

        def initialize(queue, codec, checkpoint_interval, decorator, meta_data)
          @queue = queue
          @codec = codec
          @checkpoint_interval = checkpoint_interval
          @decorator = decorator
          @meta_data = meta_data
        end

        def createEventProcessor(context)
          Processor.new(@queue, @codec.clone, @checkpoint_interval, @decorator, @meta_data)
        end

      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
logstash-input-azure_event_hubs-1.2.1	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.2.0	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.1.4	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.1.3	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.1.2	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.1.1	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.1.0	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.0.4	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.0.3	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.0.1	lib/logstash/inputs/processor_factory.rb
logstash-input-azure_event_hubs-1.0.0	lib/logstash/inputs/processor_factory.rb