lib/rrj/process/event.rb in ruby_rabbitmq_janus-3.0.0.pre.354 vs lib/rrj/process/event.rb in ruby_rabbitmq_janus-3.0.0.pre.358
- old
+ new
@@ -1,7 +1,9 @@
# frozen_string_literal: true
+require 'rrj/process/thread_runner_concern'
+
module RubyRabbitmqJanus
module Process
module Concurrencies
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
#
@@ -14,19 +16,19 @@
class Event < Concurrency
include RubyRabbitmqJanus::Process::Concurrencies::ThreadRunnerConcern
private
- def raise_nil_block
- raise RubyRabbitmqJanus::Errors::Process::Event::Run
- end
-
def name_publisher
- :publish
+ :pub_classic
end
def publisher
Rabbit::Listener::From.new(rabbit)
+ end
+
+ def raise_nil_block
+ raise RubyRabbitmqJanus::Errors::Process::Event::Run
end
end
end
end
end