Class/Module Index [+]

Quicksearch

AMQ::Client::Async::Adapter::ClassMethods

Public Instance Methods

authentication_failure_exception_class() click to toggle source

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
connect(settings = nil, &block) click to toggle source

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
logger() click to toggle source
# File lib/amq/client/async/adapter.rb, line 115
def logger
  @logger ||= begin
                require "logger"
                Logger.new(STDERR)
              end
end
logger=(logger) click to toggle source
# 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
logging() click to toggle source

@return [Boolean] Current value of logging flag.

# File lib/amq/client/async/adapter.rb, line 132
def logging
  settings[:logging]
end
logging=(boolean) click to toggle source

Turns loggin on or off.

# File lib/amq/client/async/adapter.rb, line 137
def logging=(boolean)
  settings[:logging] = boolean
end
settings() click to toggle source

Settings

# File lib/amq/client/async/adapter.rb, line 111
def settings
  @settings ||= AMQ::Client::Settings.default
end
tcp_connection_failure_exception_class() click to toggle source

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

[Validate]

Generated with the Darkfish Rdoc Generator 2.