Sha256: cb47a1145356e9dd25a80effeed2582cc767a710dc1b0829a5b30759a6962d12
Contents?: true
Size: 898 Bytes
Versions: 28
Compression:
Stored size: 898 Bytes
Contents
# frozen_string_literal: true
require 'rrj/process/thread_runner_concern'
module RubyRabbitmqJanus
module Process
module Concurrencies
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
#
# # Listen admin queue to all Janus instance
#
# Listen admin queue and sending a block code to thread listen.
# The default queue is configured in config file.
#
# @see file:/config/default.md For more information to config file used.
class EventAdmin < Concurrency
include RubyRabbitmqJanus::Process::Concurrencies::ThreadRunnerConcern
private
def name_publisher
:pub_admin
end
def publisher
Rabbit::Listener::FromAdmin.new(rabbit)
end
def raise_nil_block
raise RubyRabbitmqJanus::Errors::Process::EventAdmin::Run
end
end
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems