Contents

# frozen_string_literal: true

module RubyRabbitmqJanus
  # @author VAILLANT Jeremy <[e-mail]>
  module Janus
    module Concurrencies
      # For listen standard queue ("from-janus" by default)
      # :reek:InstanceVariableAssumption and :reek:NilCheck
      # :reek:TooManyInstanceVariables and :reek:TooManyStatements
      class Event < Concurrency
        include Singleton

        # Initialize Event object. Is used for listen an standard out queue to Janus
        def initialize
          super
          @publish = @response = nil
        end

        # Execute an block code in a thread
        def run(&block)
          @thread.join
          Thread.new do
            loop { @thread.thread_variable_get(:publish).listen_events(&block) }
          end
        end

        private

        # Initialize a thread
        def transaction_running
          Thread.current.thread_variable_set(:publish,
                                             Rabbit::Publisher::Listener.new(rabbit))
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
ruby_rabbitmq_janus-1.1.1	lib/rrj/janus/processus/event.rb
ruby_rabbitmq_janus-1.1.0	lib/rrj/janus/processus/event.rb
ruby_rabbitmq_janus-1.0.8	lib/rrj/janus/processus/event.rb
ruby_rabbitmq_janus-1.0.7	lib/rrj/janus/processus/event.rb
ruby_rabbitmq_janus-1.0.6	lib/rrj/janus/processus/event.rb