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

- old
+ new

@@ -15,12 +15,10 @@ NAME_VAR = :publish def initialize super @thread = Thread.new { initialize_thread } - rescue - raise Errors::Process::Event::Initializer end # Create a thread for execute a block code in a thread # # @param [Proc] block Block code for execute action when queue @@ -33,11 +31,9 @@ Thread.new do loop do @thread.thread_variable_get(NAME_VAR).listen_events(&block) end end - rescue - raise Errors::Process::Event::Run end private def transaction_running