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