lib/rrj/process/concurrency.rb in ruby_rabbitmq_janus-3.0.0.pre.384 vs lib/rrj/process/concurrency.rb in ruby_rabbitmq_janus-3.0.0.pre.385

@@ -26,26 +26,20 @@
 
         def initialize_thread
           @rabbit.transaction_long { transaction_running }
         rescue Interrupt
           ::Log.warn "This process has been interupted #{class_name}"
-          close
-        else
-          close
+          ::Log.warn \
+            "Close a connection with RabbitMQ instance for #{class_name}"
+          @rabbit.close
         end
 
         def info_thread
           "Create an thread -- #{class_name}"
         end
 
         def class_name
           self.class.name
-        end
-
-        def close
-          ::Log.warn \
-            "Close a connection with RabbitMQ instance for #{class_name}"
-          @rabbit.close
         end
       end
     end
   end
 end