Module: ActionSubscriber::RabbitConnection

Defined in:
lib/action_subscriber/rabbit_connection.rb

Constant Summary collapse

SUBSCRIBER_CONNECTION_MUTEX = 
::Mutex.new

Class Method Summary collapse

Class Method Details

.subscriber_connected? ⇒ Boolean

Returns:

  • (Boolean) 


7
8
9
 
# File 'lib/action_subscriber/rabbit_connection.rb', line 7

def self.subscriber_connected?
  with_connection{|connection| connection.connected? }
end

.subscriber_disconnect! ⇒ Object 



11
12
13
14
15
16
 
# File 'lib/action_subscriber/rabbit_connection.rb', line 11

def self.subscriber_disconnect!
  SUBSCRIBER_CONNECTION_MUTEX.synchronize do
    @subscriber_connection.close if @subscriber_connection
    @subscriber_connection = nil
  end
end

.with_connection ⇒ Object 



18
19
20
21
22
23
 
# File 'lib/action_subscriber/rabbit_connection.rb', line 18

def self.with_connection
  SUBSCRIBER_CONNECTION_MUTEX.synchronize do
    @subscriber_connection ||= create_connection
    yield(@subscriber_connection)
  end
end