Sha256: db6cee2898b876660c9158d3b79363800dff88d2209a0d579b5462406acb89d2
Contents?: true
Size: 1.49 KB
Versions: 19
Compression:
Stored size: 1.49 KB
Contents
# frozen_string_literal: true
module RubyRabbitmqJanus
module Process
module Concurrencies
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
# # Listen public queue to all Janus instance
#
# Listen standard 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 Event < Concurrency
include Singleton
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
# standard 'from-janus' receive a message.This block is sending to
# publisher created for this thread.
#
# @return [Thread] It's a thread who listen queue and execute action
def run(&block)
@thread.join
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
publisher = Rabbit::Listener::From.new(rabbit)
@thread.thread_variable_set(NAME_VAR, publisher)
end
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems