Class: RubyRabbitmqJanus::Process::Concurrencies::Concurrency Abstract

Inherits:

Object

• Object
• RubyRabbitmqJanus::Process::Concurrencies::Concurrency

Defined in:

lib/rrj/process/concurrency.rb

Overview

This class is abstract.

Manage thread for listener to queue : from-janus from-janus-admin

# Class for manage threads

Author:

• VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>

Direct Known Subclasses

Event, EventAdmin

Instance Method Summary

• #initialize ⇒ Concurrency constructor

  Initialize class with elements for thread communication.

Constructor Details

#initialize ⇒ Concurrency

Initialize class with elements for thread communication

# File 'lib/rrj/process/concurrency.rb', line 16

def initialize
  ::Log.info info_thread
  @rabbit = RubyRabbitmqJanus::Rabbit::Connect.new
  @lock = Mutex.new
  @condition = ConditionVariable.new
rescue
  raise Errors::Process::Concurencies::Initializer
end