- remove unnecessary thread name settings (the pipeline does this now)

lib/logstash/inputs/file.rb

@@ -66,7 +66,6 @@ class LogStash::Inputs::File < LogStash::Inputs::Base
     require "addressable/uri"
     require "filewatch/tail"
     require "digest/md5"
-    LogStash::Util::set_thread_name("input|file|#{path.join(":")}")
     @logger.info("Registering file input", :path => @path)
 
     @tail_config = {

lib/logstash/inputs/ganglia.rb

@@ -36,7 +36,6 @@ class LogStash::Inputs::Ganglia < LogStash::Inputs::Base
   def run(output_queue)
     # udp server
     Thread.new do
-      LogStash::Util::set_thread_name("input|ganglia|udp")
       begin
         udp_listener(output_queue)
       rescue => e

lib/logstash/inputs/gelf.rb

@@ -50,7 +50,6 @@ class LogStash::Inputs::Gelf < LogStash::Inputs::Base
 
   public
   def run(output_queue)
-    LogStash::Util::set_thread_name("input|gelf")
     begin
       # udp server
       udp_listener(output_queue)

lib/logstash/inputs/pipe.rb

@@ -24,7 +24,6 @@ class LogStash::Inputs::Pipe < LogStash::Inputs::Base
 
   public
   def register
-    LogStash::Util::set_thread_name("input|pipe|#{command}")
     @logger.info("Registering pipe input", :command => @command)
   end # def register
 

lib/logstash/inputs/s3.rb

@@ -53,7 +53,6 @@ class LogStash::Inputs::S3 < LogStash::Inputs::Base
 
   public
   def register
-    LogStash::Util::set_thread_name("input|s3|#{bucket}");
     @logger.info("Registering s3 input", :bucket => @bucket)
 
     if @credentials.nil?

lib/logstash/inputs/snmptrap.rb

@@ -48,7 +48,6 @@ class LogStash::Inputs::Snmptrap < LogStash::Inputs::Base
 
   public
   def run(output_queue)
-    LogStash::Util::set_thread_name("input|snmptrap|#{@community}")
     begin
       # snmp trap server
       snmptrap_listener(output_queue)

lib/logstash/inputs/sqlite.rb

@@ -125,7 +125,6 @@ class LogStash::Inputs::Sqlite < LogStash::Inputs::Base
     require "sequel"
     require "jdbc/sqlite3" 
     @host = Socket.gethostname
-    LogStash::Util::set_thread_name("input|sqlite|#{@path}")
     @logger.info("Registering sqlite input", :database => @path)
     @db = Sequel.connect("jdbc:sqlite:#{@path}") 
     @tables = get_all_tables(@db)

lib/logstash/inputs/syslog.rb

@@ -69,7 +69,6 @@ class LogStash::Inputs::Syslog < LogStash::Inputs::Base
   def run(output_queue)
     # udp server
     udp_thr = Thread.new do
-      LogStash::Util::set_thread_name("input|syslog|udp")
       begin
         udp_listener(output_queue)
       rescue => e
@@ -84,7 +83,6 @@ class LogStash::Inputs::Syslog < LogStash::Inputs::Base
 
     # tcp server
     tcp_thr = Thread.new do
-      LogStash::Util::set_thread_name("input|syslog|tcp")
       begin
         tcp_listener(output_queue)
       rescue => e

lib/logstash/inputs/udp.rb

@@ -34,7 +34,6 @@ class LogStash::Inputs::Udp < LogStash::Inputs::Base
 
   public
   def run(output_queue)
-    LogStash::Util::set_thread_name("input|udp|#{@port}")
     begin
       # udp server
       udp_listener(output_queue)

lib/logstash/inputs/websocket.rb

@@ -29,7 +29,6 @@ class LogStash::Inputs::Websocket < LogStash::Inputs::Base
   public
   def run(output_queue)
     # TODO(sissel): Implement server mode.
-    LogStash::Util::set_thread_name("<websocket")
     agent = FTW::Agent.new
     begin
       websocket = agent.websocket!(@url)