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

@@ -26,20 +26,26 @@
 
         def initialize_thread
           @rabbit.transaction_long { transaction_running }
         rescue Interrupt
           ::Log.warn "This process has been interupted #{class_name}"
-          ::Log.warn \
-            "Close a connection with RabbitMQ instance for #{class_name}"
-          @rabbit.close
+          close
+        else
+          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