Contents

# frozen_string_literal: true

module RubyRabbitmqJanus
  module Janus
    module Concurrencies
      class EventAdmin < Event
        include Singleton

        NAME_VAR = :publish_adm.freeze

        private

        def transaction_running
          publisher = Rabbit::Publisher::ListenerAdmin.new(rabbit)
          @thread.thread_variable_set(NAME_VAR, publisher)
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
ruby_rabbitmq_janus-2.5.0.pre.210	lib/rrj/janus/processus/event_admin.rb
ruby_rabbitmq_janus-2.5.0.pre.209	lib/rrj/janus/processus/event_admin.rb
ruby_rabbitmq_janus-2.4.0.pre.208	lib/rrj/janus/processus/event_admin.rb