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