Sha256: fd1cedca34ffa41ebb276ef23022c4466e388aee75893a5363e6ec2e74cb5281
Contents?: true
Size: 1.04 KB
Versions: 51
Compression:
Stored size: 1.04 KB
Contents
# frozen_string_literal: true
require 'semaphore'
module RubyRabbitmqJanus
module Rabbit
# Define an module for create an publisher
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
# # Parent class for all publisher
# This element send and read a message in rabbitmq Queue
#
# @!attribute [r] response
# @return [RubyRabbitmqJanus::Janus::Responses::Response]
# Given a Janus response
#
# @abstract Publish message in RabbitMQ
class BaseEvent
attr_reader :responses
# Define a base publisher
def initialize
@responses = []
@semaphore = Semaphore.new
@lock = Mutex.new
rescue
raise Errors::Rabbit::BaseEvent::Initialize
end
private
attr_accessor :semaphore, :lock
def return_response
@semaphore.wait
response = nil
@lock.synchronize do
response = @responses.shift
end
response
end
end
end
end
require 'rrj/rabbit/publisher/base'
require 'rrj/rabbit/listener/base'
Version data entries
51 entries across 51 versions & 1 rubygems