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