Sha256: 228c1308040c8385162d2683a776aad3e2c125c496185e05d0e3098dc3ae8676
Contents?: true
Size: 508 Bytes
Versions: 28
Compression:
Stored size: 508 Bytes
Contents
# frozen_string_literal: true
# :reek:InstanceVariableAssumption
module RubyRabbitmqJanus
module Janus
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::Publisher::ListenerAdmin.new(rabbit)
@thread.thread_variable_set(NAME_VAR, publisher)
end
end
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems