Method: MultipleMan::Connection.connection

Defined in:
lib/multiple_man/connection.rb

.connection ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/multiple_man/connection.rb', line 38

def self.connection
  @mutex.synchronize do
    @connection ||= begin
      connection = Bunny.new(
        MultipleMan.configuration.connection,
        heartbeat_interval: 5,
        automatically_recover: true,
        recover_from_connection_close: true,
        network_recovery_interval: MultipleMan.configuration.connection_recovery[:time_before_reconnect]
      )
      MultipleMan.logger.debug "Connecting to #{MultipleMan.configuration.connection}"
      connection.start

      connection
    end
  end
end