Contents

# frozen_string_literal: true

# :reek:InstanceVariableAssumption

module RubyRabbitmqJanus
  module Process
    module Concurrencies
      # Manage admin message in queue public
      # Work In Progress
      class EventAdmin < Event
        include Singleton

        NAME_VAR = :publish_adm

        private

        def transaction_running
          publisher = Rabbit::Listener::FromAdmin.n(rabbit)
          @thread.thread_variable_set(NAME_VAR, publisher)
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
ruby_rabbitmq_janus-2.7.2.pre.318	lib/rrj/process/event_admin.rb
ruby_rabbitmq_janus-2.7.2.pre.317	lib/rrj/process/event_admin.rb