lib/rrj/process/concurrency.rb in ruby_rabbitmq_janus-3.0.0.pre.336 vs lib/rrj/process/concurrency.rb in ruby_rabbitmq_janus-3.0.0.pre.351

- old
+ new

@@ -16,11 +16,9 @@ def initialize ::Log.info info_thread @rabbit = RubyRabbitmqJanus::Rabbit::Connect.new @lock = Mutex.new @condition = ConditionVariable.new - rescue - raise Errors::Process::Concurencies::Initializer end private def initialize_thread