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

Defined in:
lib/amq/client/async/adapter.rb

Instance Method Summary collapse

Instance Method Details

#authentication_failure_exception_class ⇒ Class

Can be overriden by higher-level libraries like amqp gem or bunny. Defaults to AMQ::Client::PossibleAuthenticationFailure.

Returns:

  • (Class) 


176
177
178
 
# File 'lib/amq/client/async/adapter.rb', line 176

def authentication_failure_exception_class
  @authentication_failure_exception_class ||= AMQ::Client::PossibleAuthenticationFailureError
end

#connect(settings = nil, &block) ⇒ Object

Establishes connection to AMQ broker and returns it. New connection object is yielded to the block if it is given.

Examples:

Specifying adapter via the :adapter option

AMQ::Client::Adapter.connect(:adapter => "socket")

Specifying using custom adapter class

AMQ::Client::SocketClient.connect

Parameters:

  • Connection (Hash) —

    parameters, including :adapter to use.



153
154
155
156
157
158
159
160
161
 
# File 'lib/amq/client/async/adapter.rb', line 153

def connect(settings = nil, &block)
  @settings = Settings.configure(settings)

  instance = self.new
  instance.establish_connection(settings)
  instance.register_connection_callback(&block)

  instance
end

#logger ⇒ Object 



117
118
119
120
121
122
 
# File 'lib/amq/client/async/adapter.rb', line 117

def logger
  @logger ||= begin
                require "logger"
                Logger.new(STDERR)
              end
end

#logger=(logger) ⇒ Object 



124
125
126
127
128
129
130
131
 
# File 'lib/amq/client/async/adapter.rb', line 124

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

Returns Current value of logging flag.

Returns:

  • (Boolean) —

    Current value of logging flag.



134
135
136
 
# File 'lib/amq/client/async/adapter.rb', line 134

def logging
  settings[:logging]
end

#logging=(boolean) ⇒ Object

Turns loggin on or off.



139
140
141
 
# File 'lib/amq/client/async/adapter.rb', line 139

def logging=(boolean)
  settings[:logging] = boolean
end

#settings ⇒ Object

Settings



113
114
115
 
# File 'lib/amq/client/async/adapter.rb', line 113

def settings
  @settings ||= AMQ::Client::Settings.default
end

#tcp_connection_failure_exception_class ⇒ Class

Can be overriden by higher-level libraries like amqp gem or bunny. Defaults to AMQ::Client::TCPConnectionFailed.

Returns:

  • (Class) 


168
169
170
 
# File 'lib/amq/client/async/adapter.rb', line 168

def tcp_connection_failure_exception_class
  @tcp_connection_failure_exception_class ||= AMQ::Client::TCPConnectionFailed
end