search

logstash-plugins / logstash-output-websocket

Apache License 2.0
5 stars 13 forks source link

Errno::EADDRINUSE: Address already in use - bind - Address already in use #4

Open Guisardo opened 8 years ago

Guisardo commented 8 years ago

Hi there, I cannot make the websocket output work. I need an input http, and a piped output that saves the events in elastic and also publish them in a websocket. So I had made this configuration:

input {
    http {
    }
}
output {
    elasticsearch {
        hosts => ["elastichost"]
    }
    websocket {
    }
}

But, even though I can connect to the websocket, nothing is been published. In the logs I keep seeing this error:

{:timestamp=>"2016-02-08T21:11:15.269000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}

Any ideas? I had already tried replacing the http input with the stdin, but same results. Removing the elasticsearch output didn't help ether... here are the full logs:

{:timestamp=>"2016-02-08T21:47:38.363000+0000", :message=>"Reading config file", :file=>"logstash/agent.rb", :level=>:debug, :line=>"361", :method=>"local_config"}
{:timestamp=>"2016-02-08T21:47:38.488000+0000", :message=>"Compiled pipeline code:\n        @inputs = []\n        @filters = []\n        @outputs = []\n        @periodic_flushers = []\n        @shutdown_flushers = []\n\n          @input_http_1 = plugin(\"input\", \"http\")\n\n          @inputs << @input_http_1\n\n          @output_elasticsearch_2 = plugin(\"output\", \"elasticsearch\", LogStash::Util.hash_merge_many({ \"hosts\" => [(\"elastichost\")] }))\n\n          @outputs << @output_elasticsearch_2\n\n          @output_websocket_3 = plugin(\"output\", \"websocket\")\n\n          @outputs << @output_websocket_3\n\n  define_singleton_method :filter_func do |event|\n    events = [event]\n    @logger.debug? && @logger.debug(\"filter received\", :event => event.to_hash)\n    events\n  end\n  define_singleton_method :output_func do |event|\n    targeted_outputs = []\n    @logger.debug? && @logger.debug(\"output received\", :event => event.to_hash)\n    targeted_outputs << @output_elasticsearch_2\n    targeted_outputs << @output_websocket_3\n    \n    targeted_outputs\n  end", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"55", :method=>"initialize"}
{:timestamp=>"2016-02-08T21:47:38.494000+0000", :message=>"Plugin not defined in namespace, checking for plugin file", :type=>"input", :name=>"http", :path=>"logstash/inputs/http", :level=>:debug, :file=>"logstash/plugin.rb", :line=>"76", :method=>"lookup"}
{:timestamp=>"2016-02-08T21:47:38.745000+0000", :message=>"Plugin not defined in namespace, checking for plugin file", :type=>"codec", :name=>"plain", :path=>"logstash/codecs/plain", :level=>:debug, :file=>"logstash/plugin.rb", :line=>"76", :method=>"lookup"}
{:timestamp=>"2016-02-08T21:47:38.767000+0000", :message=>"config LogStash::Codecs::Plain/@charset = \"UTF-8\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.781000+0000", :message=>"config LogStash::Inputs::Http/@codec = <LogStash::Codecs::Plain charset=>\"UTF-8\">", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.783000+0000", :message=>"config LogStash::Inputs::Http/@add_field = {}", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.787000+0000", :message=>"config LogStash::Inputs::Http/@host = \"0.0.0.0\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.797000+0000", :message=>"config LogStash::Inputs::Http/@port = 8080", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.803000+0000", :message=>"config LogStash::Inputs::Http/@threads = 4", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.805000+0000", :message=>"config LogStash::Inputs::Http/@ssl = false", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.809000+0000", :message=>"config LogStash::Inputs::Http/@additional_codecs = {\"application/json\"=>\"json\"}", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.814000+0000", :message=>"config LogStash::Inputs::Http/@response_headers = {\"Content-Type\"=>\"text/plain\"}", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:38.819000+0000", :message=>"Plugin not defined in namespace, checking for plugin file", :type=>"output", :name=>"elasticsearch", :path=>"logstash/outputs/elasticsearch", :level=>:debug, :file=>"logstash/plugin.rb", :line=>"76", :method=>"lookup"}
{:timestamp=>"2016-02-08T21:47:39.462000+0000", :message=>"config LogStash::Codecs::Plain/@charset = \"UTF-8\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.471000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@hosts = [\"elastichost\"]", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.489000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@codec = <LogStash::Codecs::Plain charset=>\"UTF-8\">", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.494000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@workers = 1", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.497000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@index = \"logstash-%{+YYYY.MM.dd}\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.500000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@manage_template = true", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.509000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@template_name = \"logstash\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.513000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@template_overwrite = false", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.515000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@parent = nil", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.521000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@flush_size = 500", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.528000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@idle_flush_time = 1", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.531000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@upsert = \"\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.534000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@doc_as_upsert = false", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.537000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@max_retries = 3", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.547000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@script = \"\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.549000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@script_type = \"inline\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.555000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@script_lang = \"\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.560000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@script_var_name = \"event\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.565000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@scripted_upsert = false", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.582000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@retry_max_interval = 2", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.583000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@retry_max_items = 500", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.586000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@action = \"index\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.590000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@path = \"/\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.595000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@ssl = false", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.598000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@ssl_certificate_verification = true", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.600000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@sniffing = false", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.605000+0000", :message=>"config LogStash::Outputs::ElasticSearch/@sniffing_delay = 5", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:39.608000+0000", :message=>"Normalizing http path", :path=>"/", :normalized=>"/", :level=>:debug, :file=>"logstash/outputs/elasticsearch/http_client_builder.rb", :line=>"14", :method=>"build"}
{:timestamp=>"2016-02-08T21:47:39.620000+0000", :message=>"Elasticsearch HTTP client options", :hosts=>["http://elastichost:9200/"], :ssl=>nil, :transport_options=>{:socket_timeout=>0, :request_timeout=>0, :proxy=>nil}, :transport_class=>Elasticsearch::Transport::Transport::HTTP::Manticore, :level=>:debug, :file=>"logstash/outputs/elasticsearch/http_client.rb", :line=>"134", :method=>"build_client"}
{:timestamp=>"2016-02-08T21:47:40.110000+0000", :message=>"Using mapping template from", :path=>nil, :level=>:info, :file=>"logstash/outputs/elasticsearch/template_manager.rb", :line=>"6", :method=>"install_template"}
{:timestamp=>"2016-02-08T21:47:40.544000+0000", :message=>"Attempting to install template", :manage_template=>{"template"=>"logstash-*", "settings"=>{"index.refresh_interval"=>"5s"}, "mappings"=>{"_default_"=>{"_all"=>{"enabled"=>true, "omit_norms"=>true}, "dynamic_templates"=>[{"message_field"=>{"match"=>"message", "match_mapping_type"=>"string", "mapping"=>{"type"=>"string", "index"=>"analyzed", "omit_norms"=>true, "fielddata"=>{"format"=>"disabled"}}}}, {"string_fields"=>{"match"=>"*", "match_mapping_type"=>"string", "mapping"=>{"type"=>"string", "index"=>"analyzed", "omit_norms"=>true, "fielddata"=>{"format"=>"disabled"}, "fields"=>{"raw"=>{"type"=>"string", "index"=>"not_analyzed", "doc_values"=>true, "ignore_above"=>256}}}}}, {"float_fields"=>{"match"=>"*", "match_mapping_type"=>"float", "mapping"=>{"type"=>"float", "doc_values"=>true}}}, {"double_fields"=>{"match"=>"*", "match_mapping_type"=>"double", "mapping"=>{"type"=>"double", "doc_values"=>true}}}, {"byte_fields"=>{"match"=>"*", "match_mapping_type"=>"byte", "mapping"=>{"type"=>"byte", "doc_values"=>true}}}, {"short_fields"=>{"match"=>"*", "match_mapping_type"=>"short", "mapping"=>{"type"=>"short", "doc_values"=>true}}}, {"integer_fields"=>{"match"=>"*", "match_mapping_type"=>"integer", "mapping"=>{"type"=>"integer", "doc_values"=>true}}}, {"long_fields"=>{"match"=>"*", "match_mapping_type"=>"long", "mapping"=>{"type"=>"long", "doc_values"=>true}}}, {"date_fields"=>{"match"=>"*", "match_mapping_type"=>"date", "mapping"=>{"type"=>"date", "doc_values"=>true}}}, {"geo_point_fields"=>{"match"=>"*", "match_mapping_type"=>"geo_point", "mapping"=>{"type"=>"geo_point", "doc_values"=>true}}}], "properties"=>{"@timestamp"=>{"type"=>"date", "doc_values"=>true}, "@version"=>{"type"=>"string", "index"=>"not_analyzed", "doc_values"=>true}, "geoip"=>{"type"=>"object", "dynamic"=>true, "properties"=>{"ip"=>{"type"=>"ip", "doc_values"=>true}, "location"=>{"type"=>"geo_point", "doc_values"=>true}, "latitude"=>{"type"=>"float", "doc_values"=>true}, "longitude"=>{"type"=>"float", "doc_values"=>true}}}}}}}, :level=>:info, :file=>"logstash/outputs/elasticsearch/template_manager.rb", :line=>"8", :method=>"install_template"}
{:timestamp=>"2016-02-08T21:47:40.897000+0000", :message=>"Found existing Elasticsearch template. Skipping template management", :name=>"logstash", :level=>:debug, :file=>"logstash/outputs/elasticsearch/http_client.rb", :line=>"30", :method=>"template_install"}
{:timestamp=>"2016-02-08T21:47:40.905000+0000", :message=>"New Elasticsearch output", :class=>"LogStash::Outputs::ElasticSearch", :hosts=>["elastichost"], :level=>:info, :file=>"logstash/outputs/elasticsearch/common.rb", :line=>"19", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:40.907000+0000", :message=>"Will start workers for output", :worker_count=>1, :class=>LogStash::Outputs::ElasticSearch, :level=>:debug, :file=>"logstash/output_delegator.rb", :line=>"34", :method=>"initialize"}
{:timestamp=>"2016-02-08T21:47:40.916000+0000", :message=>"Plugin not defined in namespace, checking for plugin file", :type=>"output", :name=>"websocket", :path=>"logstash/outputs/websocket", :level=>:debug, :file=>"logstash/plugin.rb", :line=>"76", :method=>"lookup"}
{:timestamp=>"2016-02-08T21:47:40.942000+0000", :message=>"config LogStash::Codecs::Plain/@charset = \"UTF-8\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:40.951000+0000", :message=>"config LogStash::Outputs::WebSocket/@codec = <LogStash::Codecs::Plain charset=>\"UTF-8\">", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:40.976000+0000", :message=>"config LogStash::Outputs::WebSocket/@workers = 1", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:41.005000+0000", :message=>"config LogStash::Outputs::WebSocket/@host = \"0.0.0.0\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:41.007000+0000", :message=>"config LogStash::Outputs::WebSocket/@port = 3232", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:41.908000+0000", :message=>"Will start workers for output", :worker_count=>1, :class=>LogStash::Outputs::WebSocket, :level=>:debug, :file=>"logstash/output_delegator.rb", :line=>"34", :method=>"initialize"}
{:timestamp=>"2016-02-08T21:47:41.940000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:40 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:41.954000+0000", :message=>"Plugin not defined in namespace, checking for plugin file", :type=>"codec", :name=>"json", :path=>"logstash/codecs/json", :level=>:debug, :file=>"logstash/plugin.rb", :line=>"76", :method=>"lookup"}
{:timestamp=>"2016-02-08T21:47:41.985000+0000", :message=>"config LogStash::Codecs::JSON/@charset = \"UTF-8\"", :level=>:debug, :file=>"logstash/config/mixin.rb", :line=>"122", :method=>"config_init"}
{:timestamp=>"2016-02-08T21:47:41.993000+0000", :message=>"Normalizing http path", :path=>"/", :normalized=>"/", :level=>:debug, :file=>"logstash/outputs/elasticsearch/http_client_builder.rb", :line=>"14", :method=>"build"}
{:timestamp=>"2016-02-08T21:47:42.000000+0000", :message=>"Elasticsearch HTTP client options", :hosts=>["http://elastichost:9200/"], :ssl=>nil, :transport_options=>{:socket_timeout=>0, :request_timeout=>0, :proxy=>nil}, :transport_class=>Elasticsearch::Transport::Transport::HTTP::Manticore, :level=>:debug, :file=>"logstash/outputs/elasticsearch/http_client.rb", :line=>"134", :method=>"build_client"}
{:timestamp=>"2016-02-08T21:47:42.015000+0000", :message=>"Using mapping template from", :path=>nil, :level=>:info, :file=>"logstash/outputs/elasticsearch/template_manager.rb", :line=>"6", :method=>"install_template"}
{:timestamp=>"2016-02-08T21:47:42.040000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:47:42.084000+0000", :message=>"Attempting to install template", :manage_template=>{"template"=>"logstash-*", "settings"=>{"index.refresh_interval"=>"5s"}, "mappings"=>{"_default_"=>{"_all"=>{"enabled"=>true, "omit_norms"=>true}, "dynamic_templates"=>[{"message_field"=>{"match"=>"message", "match_mapping_type"=>"string", "mapping"=>{"type"=>"string", "index"=>"analyzed", "omit_norms"=>true, "fielddata"=>{"format"=>"disabled"}}}}, {"string_fields"=>{"match"=>"*", "match_mapping_type"=>"string", "mapping"=>{"type"=>"string", "index"=>"analyzed", "omit_norms"=>true, "fielddata"=>{"format"=>"disabled"}, "fields"=>{"raw"=>{"type"=>"string", "index"=>"not_analyzed", "doc_values"=>true, "ignore_above"=>256}}}}}, {"float_fields"=>{"match"=>"*", "match_mapping_type"=>"float", "mapping"=>{"type"=>"float", "doc_values"=>true}}}, {"double_fields"=>{"match"=>"*", "match_mapping_type"=>"double", "mapping"=>{"type"=>"double", "doc_values"=>true}}}, {"byte_fields"=>{"match"=>"*", "match_mapping_type"=>"byte", "mapping"=>{"type"=>"byte", "doc_values"=>true}}}, {"short_fields"=>{"match"=>"*", "match_mapping_type"=>"short", "mapping"=>{"type"=>"short", "doc_values"=>true}}}, {"integer_fields"=>{"match"=>"*", "match_mapping_type"=>"integer", "mapping"=>{"type"=>"integer", "doc_values"=>true}}}, {"long_fields"=>{"match"=>"*", "match_mapping_type"=>"long", "mapping"=>{"type"=>"long", "doc_values"=>true}}}, {"date_fields"=>{"match"=>"*", "match_mapping_type"=>"date", "mapping"=>{"type"=>"date", "doc_values"=>true}}}, {"geo_point_fields"=>{"match"=>"*", "match_mapping_type"=>"geo_point", "mapping"=>{"type"=>"geo_point", "doc_values"=>true}}}], "properties"=>{"@timestamp"=>{"type"=>"date", "doc_values"=>true}, "@version"=>{"type"=>"string", "index"=>"not_analyzed", "doc_values"=>true}, "geoip"=>{"type"=>"object", "dynamic"=>true, "properties"=>{"ip"=>{"type"=>"ip", "doc_values"=>true}, "location"=>{"type"=>"geo_point", "doc_values"=>true}, "latitude"=>{"type"=>"float", "doc_values"=>true}, "longitude"=>{"type"=>"float", "doc_values"=>true}}}}}}}, :level=>:info, :file=>"logstash/outputs/elasticsearch/template_manager.rb", :line=>"8", :method=>"install_template"}
{:timestamp=>"2016-02-08T21:47:42.096000+0000", :message=>"Found existing Elasticsearch template. Skipping template management", :name=>"logstash", :level=>:debug, :file=>"logstash/outputs/elasticsearch/http_client.rb", :line=>"30", :method=>"template_install"}
{:timestamp=>"2016-02-08T21:47:42.112000+0000", :message=>"New Elasticsearch output", :class=>"LogStash::Outputs::ElasticSearch", :hosts=>["elastichost"], :level=>:info, :file=>"logstash/outputs/elasticsearch/common.rb", :line=>"19", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:42.125000+0000", :message=>"Starting pipeline", :id=>"base", :pipeline_workers=>1, :batch_size=>125, :batch_delay=>5, :max_inflight=>125, :level=>:info, :file=>"logstash/pipeline.rb", :line=>"162", :method=>"start_workers"}
{:timestamp=>"2016-02-08T21:47:42.133000+0000", :message=>"Pipeline started", :level=>:info, :file=>"logstash/pipeline.rb", :line=>"127", :method=>"run"}
{:timestamp=>"2016-02-08T21:47:42.245000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:42.949000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:41 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:43.131000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:42 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:43.289000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:43.968000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:42 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:44.138000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:43 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:44.351000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:44.978000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:43 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:45.143000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:44 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:45.850000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:45.985000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:44 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:46.148000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:45 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:46.886000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:46.989000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:45 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:47.140000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:47:47.153000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:46 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:47.943000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:47.996000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:46 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:48.157000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:47 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:49.002000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:47 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:49.029000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:49.162000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:48 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:50.008000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:49 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:50.103000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:50.167000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:49 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:51.024000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:50 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:51.143000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:51.174000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:50 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:52.035000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:51 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:52.140000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:47:52.175000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:52.180000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:51 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:53.040000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:52 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:53.207000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:52 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:53.226000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:54.043000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:53 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:54.211000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:53 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:54.345000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:54.877000+0000", :message=>"New websocket client", :level=>:debug, :file=>"logstash/outputs/websocket/app.rb", :line=>"19", :method=>"HEAD /"}
{:timestamp=>"2016-02-08T21:47:55.047000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:54 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:55.216000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:54 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:55.397000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:56.056000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:55 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:56.219000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:55 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:56.440000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:57.063000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:56 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:57.142000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:47:57.225000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:56 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:57.512000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:58.069000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:57 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:58.232000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:57 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:58.539000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:59.080000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:58 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:59.238000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:58 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:47:59.575000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:47:59.761000+0000", :message=>"New websocket client", :level=>:debug, :file=>"logstash/outputs/websocket/app.rb", :line=>"19", :method=>"HEAD /"}
{:timestamp=>"2016-02-08T21:48:00.098000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:59 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:00.244000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:47:59 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:00.638000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:01.105000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:00 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:01.249000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:00 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:01.678000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:02.115000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:01 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:02.146000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:02.256000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:01 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:02.740000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:03.122000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:02 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:03.261000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:02 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:04.126000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:04.137000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:03 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:04.265000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:03 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:05.149000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:04 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:05.204000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:05.268000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:04 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:05.926000+0000", :message=>"filter received", :event=>{"message"=>"test event\n", "@version"=>"1", "@timestamp"=>"2016-02-08T21:48:05.228Z", "host"=>"192.168.99.1", "headers"=>{"content_type"=>"text/plain;charset=UTF-8", "request_method"=>"POST", "request_path"=>"/", "request_uri"=>"/", "http_version"=>"HTTP/1.1", "http_host"=>"192.168.99.100:8080", "http_connection"=>"keep-alive", "content_length"=>"12", "http_cache_control"=>"no-cache", "http_origin"=>"chrome-extension://fhbjgbiflinjbdggehcddcbncdddomop", "http_user_agent"=>"Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/48.0.2564.103 Safari/537.36", "http_postman_token"=>"67253629-ef30-d8bd-969a-2dccf9802a67", "http_accept"=>"*/*", "http_dnt"=>"1", "http_accept_encoding"=>"gzip, deflate", "http_accept_language"=>"es,en-US;q=0.8,en;q=0.6,pt;q=0.4"}}, :level=>:debug, :file=>"(eval)", :line=>"21", :method=>"filter_func"}
{:timestamp=>"2016-02-08T21:48:05.935000+0000", :message=>"output received", :event=>{"message"=>"test event\n", "@version"=>"1", "@timestamp"=>"2016-02-08T21:48:05.228Z", "host"=>"192.168.99.1", "headers"=>{"content_type"=>"text/plain;charset=UTF-8", "request_method"=>"POST", "request_path"=>"/", "request_uri"=>"/", "http_version"=>"HTTP/1.1", "http_host"=>"192.168.99.100:8080", "http_connection"=>"keep-alive", "content_length"=>"12", "http_cache_control"=>"no-cache", "http_origin"=>"chrome-extension://fhbjgbiflinjbdggehcddcbncdddomop", "http_user_agent"=>"Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/48.0.2564.103 Safari/537.36", "http_postman_token"=>"67253629-ef30-d8bd-969a-2dccf9802a67", "http_accept"=>"*/*", "http_dnt"=>"1", "http_accept_encoding"=>"gzip, deflate", "http_accept_language"=>"es,en-US;q=0.8,en;q=0.6,pt;q=0.4"}}, :level=>:debug, :file=>"(eval)", :line=>"26", :method=>"output_func"}
{:timestamp=>"2016-02-08T21:48:06.153000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:05 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:06.236000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:06.273000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:05 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:07.157000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:06 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:07.155000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:07.279000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:06 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:07.292000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:08.166000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:07 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:08.283000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:07 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:08.341000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:09.174000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:08 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:09.288000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:08 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:09.368000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:10.198000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:09 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:10.293000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:09 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:10.399000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:11.205000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:10 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:11.297000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:10 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:11.438000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:12.164000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:12.212000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:11 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:12.313000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:11 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:12.463000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:13.219000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:12 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:13.325000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:12 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:13.493000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:14.223000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:13 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:14.329000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:13 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:14.554000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:15.229000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:14 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:15.334000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:14 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:15.576000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:16.241000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:15 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:16.338000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:15 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:16.622000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:17.167000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:17.247000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:16 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:17.345000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:16 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:17.665000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:18.256000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:17 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:18.351000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:17 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:18.740000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:19.261000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:18 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:19.356000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:18 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:19.785000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:20.265000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:19 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:20.361000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:19 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:20.744000+0000", :message=>"filter received", :event=>{"message"=>"test event\n", "@version"=>"1", "@timestamp"=>"2016-02-08T21:48:20.044Z", "host"=>"192.168.99.1", "headers"=>{"content_type"=>"text/plain;charset=UTF-8", "request_method"=>"POST", "request_path"=>"/", "request_uri"=>"/", "http_version"=>"HTTP/1.1", "http_host"=>"192.168.99.100:8080", "http_connection"=>"keep-alive", "content_length"=>"12", "http_cache_control"=>"no-cache", "http_origin"=>"chrome-extension://fhbjgbiflinjbdggehcddcbncdddomop", "http_user_agent"=>"Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/48.0.2564.103 Safari/537.36", "http_postman_token"=>"e70e076d-3599-6300-58bf-fce540d052ee", "http_accept"=>"*/*", "http_dnt"=>"1", "http_accept_encoding"=>"gzip, deflate", "http_accept_language"=>"es,en-US;q=0.8,en;q=0.6,pt;q=0.4"}}, :level=>:debug, :file=>"(eval)", :line=>"21", :method=>"filter_func"}
{:timestamp=>"2016-02-08T21:48:20.752000+0000", :message=>"output received", :event=>{"message"=>"test event\n", "@version"=>"1", "@timestamp"=>"2016-02-08T21:48:20.044Z", "host"=>"192.168.99.1", "headers"=>{"content_type"=>"text/plain;charset=UTF-8", "request_method"=>"POST", "request_path"=>"/", "request_uri"=>"/", "http_version"=>"HTTP/1.1", "http_host"=>"192.168.99.100:8080", "http_connection"=>"keep-alive", "content_length"=>"12", "http_cache_control"=>"no-cache", "http_origin"=>"chrome-extension://fhbjgbiflinjbdggehcddcbncdddomop", "http_user_agent"=>"Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/48.0.2564.103 Safari/537.36", "http_postman_token"=>"e70e076d-3599-6300-58bf-fce540d052ee", "http_accept"=>"*/*", "http_dnt"=>"1", "http_accept_encoding"=>"gzip, deflate", "http_accept_language"=>"es,en-US;q=0.8,en;q=0.6,pt;q=0.4"}}, :level=>:debug, :file=>"(eval)", :line=>"26", :method=>"output_func"}
{:timestamp=>"2016-02-08T21:48:20.842000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:21.274000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:20 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:21.365000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:20 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:21.867000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:22.173000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:22.278000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:21 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:22.371000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:21 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:22.895000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:23.282000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:22 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:23.374000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:22 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:23.940000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:24.286000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:23 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:24.380000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:23 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:24.973000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:25.291000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:24 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:25.383000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:24 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:25.998000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:26.296000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:25 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:26.385000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:25 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:27.176000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:27.305000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:26 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:27.391000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:26 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:27.567000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:28.309000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:27 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:28.396000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:27 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:28.602000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:29.316000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:28 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:29.399000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:28 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:29.626000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:30.322000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:29 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:30.403000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:29 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:30.666000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:31.328000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:30 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:31.406000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:30 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:31.694000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:32.178000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:32.334000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:31 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:32.410000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:31 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:32.718000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:33.339000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:32 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:33.415000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:32 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:33.755000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:34.345000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:33 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:34.420000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:33 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:34.838000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:35.350000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:34 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:35.425000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:34 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:35.903000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:36.356000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:35 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:36.430000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:35 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:36.955000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:37.180000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:37.359000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:36 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:37.435000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:36 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:37.983000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:38.362000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:37 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:38.439000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:37 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:39.051000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:39.366000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:38 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:39.445000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:38 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:40.091000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:40.368000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:39 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:40.448000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:39 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:41.128000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:41.228000+0000", :message=>"filter received", :event=>{"message"=>"test event\n", "@version"=>"1", "@timestamp"=>"2016-02-08T21:48:40.515Z", "host"=>"192.168.99.1", "headers"=>{"content_type"=>"text/plain;charset=UTF-8", "request_method"=>"POST", "request_path"=>"/", "request_uri"=>"/", "http_version"=>"HTTP/1.1", "http_host"=>"192.168.99.100:8080", "http_connection"=>"keep-alive", "content_length"=>"11", "http_cache_control"=>"no-cache", "http_origin"=>"chrome-extension://fhbjgbiflinjbdggehcddcbncdddomop", "http_user_agent"=>"Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/48.0.2564.103 Safari/537.36", "http_postman_token"=>"8523047a-8776-8b8b-f9c7-c3e58f1dab28", "http_accept"=>"*/*", "http_dnt"=>"1", "http_accept_encoding"=>"gzip, deflate", "http_accept_language"=>"es,en-US;q=0.8,en;q=0.6,pt;q=0.4"}}, :level=>:debug, :file=>"(eval)", :line=>"21", :method=>"filter_func"}
{:timestamp=>"2016-02-08T21:48:41.230000+0000", :message=>"output received", :event=>{"message"=>"test event\n", "@version"=>"1", "@timestamp"=>"2016-02-08T21:48:40.515Z", "host"=>"192.168.99.1", "headers"=>{"content_type"=>"text/plain;charset=UTF-8", "request_method"=>"POST", "request_path"=>"/", "request_uri"=>"/", "http_version"=>"HTTP/1.1", "http_host"=>"192.168.99.100:8080", "http_connection"=>"keep-alive", "content_length"=>"11", "http_cache_control"=>"no-cache", "http_origin"=>"chrome-extension://fhbjgbiflinjbdggehcddcbncdddomop", "http_user_agent"=>"Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/48.0.2564.103 Safari/537.36", "http_postman_token"=>"8523047a-8776-8b8b-f9c7-c3e58f1dab28", "http_accept"=>"*/*", "http_dnt"=>"1", "http_accept_encoding"=>"gzip, deflate", "http_accept_language"=>"es,en-US;q=0.8,en;q=0.6,pt;q=0.4"}}, :level=>:debug, :file=>"(eval)", :line=>"26", :method=>"output_func"}
{:timestamp=>"2016-02-08T21:48:41.373000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:40 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:41.452000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:40 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:42.173000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:42.180000+0000", :message=>"Pushing flush onto pipeline", :level=>:debug, :file=>"logstash/pipeline.rb", :line=>"432", :method=>"flush"}
{:timestamp=>"2016-02-08T21:48:42.378000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:41 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:42.456000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:41 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:43.382000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:42 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:43.460000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:42 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:43.614000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:44.388000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:43 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:44.466000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:43 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:44.842000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}
{:timestamp=>"2016-02-08T21:48:45.390000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x60c65422 @operations_mutex=#<Mutex:0x6e01a64a>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x6a3e3f52>, @submit_proc=#<Proc:0x7d099af0@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:44 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x51cad2e7>, @buffer=[], @flush_thread=#<Thread:0x489c9075 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:45.470000+0000", :message=>"Flushing buffer at interval", :instance=>"#<LogStash::Outputs::ElasticSearch::Buffer:0x2fe739e8 @operations_mutex=#<Mutex:0x2120d264>, @max_size=500, @operations_lock=#<Java::JavaUtilConcurrentLocks::ReentrantLock:0x251f5298>, @submit_proc=#<Proc:0x76a385cd@/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-elasticsearch-2.4.1-java/lib/logstash/outputs/elasticsearch/common.rb:55>, @logger=#<Cabin::Channel:0x1ed940ed @metrics=#<Cabin::Metrics:0x50628cb @metrics_lock=#<Mutex:0x4f13533e>, @metrics={}, @channel=#<Cabin::Channel:0x1ed940ed ...>>, @subscriber_lock=#<Mutex:0x7e7c9e36>, @level=:debug, @subscribers={13106=>#<Cabin::Outputs::IO:0x1e0242c9 @io=#<IO:fd 1>, @lock=#<Mutex:0x4b5d6894>>}, @data={}>, @last_flush=2016-02-08 21:48:44 +0000, @flush_interval=1, @stopping=#<Concurrent::AtomicBoolean:0x5137da8f>, @buffer=[], @flush_thread=#<Thread:0xe63d9a3 run>>", :interval=>1, :level=>:debug, :file=>"logstash/outputs/elasticsearch/buffer.rb", :line=>"90", :method=>"interval_flush"}
{:timestamp=>"2016-02-08T21:48:46.072000+0000", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error, :file=>"logstash/outputs/websocket.rb", :line=>"33", :method=>"register"}

Let me know if you need more info. Best.

Guisardo commented 8 years ago

So, I'd found this elasticsearch plugin that does de websocket magic: https://github.com/jurgc11/es-change-feed-plugin

Still, it would be nice to fix the logstash plugin :)

Ulrhol commented 8 years ago

I believe this is a bug in output_delegator.rb

First there is a registering of all additional (if more than one) output workers: @workers += (@worker_count - 1).times.map do inst = @klass.new(*args) inst.register inst end

Then there is another registering of each worker: def register @workers.each {|w| w.register} end

So I altered the latter to do nothing and it worked for me: def register @logger.info("Worker should already be registered, skipping") end

In addition to that the websocket is not threadsafe so there can be only one worker, regardless of how many you tell it to spawn. To ensure this works after logstash 2.2+ you have to make sure it has the following code in the class definition:

if self.respond_to?(:workers_not_supported!) # Check for v2.2+ API declare_workers_not_supported!("Websocket only supports one w orker to prevent text overlap!") end

seang-es commented 8 years ago

Hi @Ulrhol, it appears that the PR you filed failed in test because you have not signed the Contributor Licensing Agreement. Would you mind signing that so the code can be incorporated? Thanks!

jasonehines commented 8 years ago

After restarting logstash, I'm getting the websocket already in use message too. I'm running version 2.2.4 of logstash.

{:timestamp=>"2016-06-27T15:16:35.034000-0400", :message=>"websocket server failed", :exception=>#<Errno::EADDRINUSE: Address already in use - bind - Address already in use>, :level=>:error}