- migrate up some code

bin/list_log_keys.rb

@@ -1,13 +1,13 @@
 #!/usr/bin/ruby
 #
 require 'rubygems'
-require "socket"
-require "lib/net/client"
-require "lib/net/messages/logkeys"
+require 'socket'
+require 'lib/net/messages/logkeys'
+require 'mqrpc'
 
 Thread::abort_on_exception = true
 
-class LogKeysClient < LogStash::Net::MessageClient
+class LogKeysClient < MQRPC::Agent
   attr_reader :keys
 
   def initialize(opts)

bin/list_log_types.rb

@@ -2,12 +2,12 @@
 #
 require 'rubygems'
 require "socket"
-require "lib/net/client"
-require "lib/net/messages/logtypes"
+require 'lib/net/messages/logtypes'
+require 'mqprc'
 
 Thread::abort_on_exception = true
 
-class LogTypesClient < LogStash::Net::MessageClient
+class LogTypesClient < MQPRC::Agent
   attr_reader :types
 
   def initialize(opts)

lib/net/clients/search.rb

@@ -1,7 +1,6 @@
 #!/usr/bin/ruby
 #
 require "rubygems"
-require "lib/net/client"
 require "lib/config/base"
 require "lib/net/messages/directory"
 require "lib/net/messages/indexevent"
@@ -12,7 +11,7 @@ require "set"
 
 
 module LogStash::Net::Clients
-  class Search < LogStash::Net::MessageClient
+  class Search < MQRPC::Agent
     attr_accessor :indexers
     attr_reader :hits
     attr_reader :responding
@@ -25,7 +24,7 @@ module LogStash::Net::Clients
       @results = []
       @result_mutex = Mutex.new
       config = LogStash::Config::BaseConfig.new(config_file)
-      super(config, "search")
+      super(config)
       start
     end