- disable signal-invoked shutdown for now. Need to refactor so it'll be

easier to do this.

lib/logstash/agent.rb

@@ -429,15 +429,15 @@ class LogStash::Agent
       ##end
     #end # SIGUSR1
 
-    Signal.trap("INT") do
-      @logger.warn("SIGINT received, shutting down.")
-      shutdown
-    end
+    #Signal.trap("INT") do
+      #@logger.warn("SIGINT received, shutting down.")
+      #shutdown
+    #end
 
-    Signal.trap("TERM") do
-      @logger.warn("SIGTERM received, shutting down.")
-      shutdown
-    end
+    #Signal.trap("TERM") do
+      #@logger.warn("SIGTERM received, shutting down.")
+      #shutdown
+    #end
   end # def register_signal_handlers
 
   private

lib/logstash/inputs/beanstalk.rb

@@ -42,4 +42,9 @@ class LogStash::Inputs::Beanstalk < LogStash::Inputs::Base
       job.delete
     end
   end # def run
+
+  public
+  def teardown
+    @beanstalk.close rescue nil
+  end # def teardown
 end # class LogStash::Inputs::Beanstalk