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
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 |