Module: Harmoniser::Mock::MockConnectableMethods

Defined in:
lib/harmoniser/mock.rb

Instance Method Summary collapse

Instance Method Details

#connection(configuration = Harmoniser.configuration) ⇒ Object 



35
36
37
38
39
40
41
42
43
 
# File 'lib/harmoniser/mock.rb', line 35

def connection(configuration = Harmoniser.configuration)
  return super unless Harmoniser::Mock.mocked?

  Harmoniser::Connectable::MUTEX.synchronize do
    @mock_connection ||= Harmoniser::Mock::Connection.new(configuration.connection_opts, error_handler: configuration.error_handler)
    @mock_connection.start unless @mock_connection.open? || @mock_connection.recovering_from_network_failure?
    @mock_connection
  end
end

#connection? ⇒ Boolean

Returns:

  • (Boolean) 


45
46
47
48
 
# File 'lib/harmoniser/mock.rb', line 45

def connection?
  return super unless Harmoniser::Mock.mocked?
  !!defined?(@mock_connection)
end

#create_channel(consumer_pool_size: 1, consumer_pool_shutdown_timeout: 60) ⇒ Object 



50
51
52
53
 
# File 'lib/harmoniser/mock.rb', line 50

def create_channel(consumer_pool_size: 1, consumer_pool_shutdown_timeout: 60)
  return super unless Harmoniser::Mock.mocked?
  connection.create_channel(nil, consumer_pool_size, false, consumer_pool_shutdown_timeout)
end