Sha256: 78e430307b5ddd5c0ee46815e9cfe2942d0757e5f4e428c69f86eb7a586a530c
Contents?: true
Size: 649 Bytes
Versions: 14
Compression:
Stored size: 649 Bytes
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
14 entries across 14 versions & 1 rubygems