Added missing self.input_queue init.
New experimental module ElasticSearchMultiProcessSink.py