Sha256: 6684500e8b59143276cd2add35480ce35b5518e07b39c6813be263a4b83217c8
Contents?: true
Size: 1.15 KB
Versions: 15
Compression:
Stored size: 1.15 KB
Contents
# frozen_string_literal: true
module RubyRabbitmqJanus
module Process
# Modules for create autonomous process
module Concurrencies
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
#
# # Class for manage threads
#
# @abstract Manage thread for listener to queue :
# from-janus
# from-janus-admin
class Concurrency
# Initialize class with elements for thread communication
def initialize
::Log.info info_thread
@rabbit = RubyRabbitmqJanus::Rabbit::Connect.new
@lock = Mutex.new
@condition = ConditionVariable.new
rescue
raise Errors::Process::Concurencies::Initializer
end
private
def initialize_thread
@rabbit.transaction_long { transaction_running }
rescue Interrupt
::Log.info "Stop transaction #{self.class.name}"
@rabbit.close
end
def info_thread
"Create an thread -- #{self.class.name}"
end
attr_reader :lock, :condition, :rabbit
end
end
end
end
require 'rrj/process/event'
require 'rrj/process/event_admin'
Version data entries
15 entries across 15 versions & 1 rubygems