Can be overriden by higher-level libraries like amqp gem or bunny. Defaults to AMQ::Client::PossibleAuthenticationFailure.
@return [Class]
# File lib/amq/client/async/adapter.rb, line 174 def authentication_failure_exception_class @authentication_failure_exception_class ||= AMQ::Client::PossibleAuthenticationFailureError end
Establishes connection to AMQ broker and returns it. New connection object is yielded to the block if it is given.
@example Specifying adapter via the :adapter option
AMQ::Client::Adapter.connect(:adapter => "socket")
@example Specifying using custom adapter class
AMQ::Client::SocketClient.connect
@param [Hash] Connection parameters, including :adapter to use. @api public
# File lib/amq/client/async/adapter.rb, line 151 def connect(settings = nil, &block) @settings = Settings.configure(settings) instance = self.new instance.establish_connection(settings) instance.register_connection_callback(&block) instance end
# File lib/amq/client/async/adapter.rb, line 115 def logger @logger ||= begin require "logger" Logger.new(STDERR) end end
# File lib/amq/client/async/adapter.rb, line 122 def logger=(logger) methods = AMQ::Client::Logging::REQUIRED_METHODS unless methods.all? { |method| logger.respond_to?(method) } raise AMQ::Client::Logging::IncompatibleLoggerError.new(methods) end @logger = logger end
@return [Boolean] Current value of logging flag.
# File lib/amq/client/async/adapter.rb, line 132 def logging settings[:logging] end
Turns loggin on or off.
# File lib/amq/client/async/adapter.rb, line 137 def logging=(boolean) settings[:logging] = boolean end
# File lib/amq/client/async/adapter.rb, line 111 def settings @settings ||= AMQ::Client::Settings.default end
Can be overriden by higher-level libraries like amqp gem or bunny. Defaults to AMQ::Client::TCPConnectionFailed.
@return [Class]
# File lib/amq/client/async/adapter.rb, line 166 def tcp_connection_failure_exception_class @tcp_connection_failure_exception_class ||= AMQ::Client::TCPConnectionFailed end
Generated with the Darkfish Rdoc Generator 2.