Module: Fleck

Defined in:
lib/fleck.rb,
lib/fleck/core.rb,
lib/fleck/client.rb,
lib/fleck/version.rb,
lib/fleck/consumer.rb,
lib/fleck/configuration.rb,
lib/fleck/core/consumer.rb,
lib/fleck/client/request.rb,
lib/fleck/client/response.rb,
lib/fleck/core/consumer/base.rb,
lib/fleck/core/consumer/logger.rb,
lib/fleck/core/consumer/actions.rb,
lib/fleck/core/consumer/request.rb,
lib/fleck/utilities/host_rating.rb,
lib/fleck/core/consumer/response.rb,
lib/fleck/core/consumer/decorators.rb,
lib/fleck/core/consumer/validation.rb,
lib/fleck/core/consumer/action_param.rb,
lib/fleck/core/consumer/configuration.rb,
lib/fleck/core/consumer/helpers_definers.rb,
lib/fleck/core/consumer/response_helpers.rb

Overview

Open ‘Fleck` module to add `HostRating` class.

Defined Under Namespace

Modules: Core, Loggable Classes: Client, Configuration, Consumer, HostRating

Constant Summary collapse

VERSION = 
'2.1.0'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.config ⇒ Object (readonly)

Returns the value of attribute config.



36
37
38
 
# File 'lib/fleck.rb', line 36

def config
  @config
end

.consumers ⇒ Object (readonly)

Returns the value of attribute consumers.



36
37
38
 
# File 'lib/fleck.rb', line 36

def consumers
  @consumers
end

Class Method Details

.configure {|@config| ... } ⇒ Object

Yields:



38
39
40
41
 
# File 'lib/fleck.rb', line 38

def configure
  yield @config if block_given?
  @config
end

.connection(options = {}) ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/fleck.rb', line 53

def connection(options = {})
  opts = Fleck.config.default_options.merge(options)
  key  = "ampq://#{opts[:user]}@#{opts[:host]}:#{opts[:port]}#{opts[:vhost]}"
  conn = @connections[key]
  if !conn || conn.closed?
    opts[:logger] = Fleck.logger.clone
    opts[:logger].progname += '::Bunny'
    logger.info "New connection #{key}"
    conn = Bunny.new(opts)
    conn.start
    @connections[key] = conn
  end

  conn
end

.logger ⇒ Object 



43
44
45
 
# File 'lib/fleck.rb', line 43

def logger
  @config.logger
end

.register_consumer(consumer_class) ⇒ Object 



47
48
49
50
51
 
# File 'lib/fleck.rb', line 47

def register_consumer(consumer_class)
  return if @consumers.include?(consumer_class)

  @consumers << consumer_class
end

.terminate ⇒ Object 



69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/fleck.rb', line 69

def terminate
  @connections.each do |key, connection|
    Fleck.logger.info "Closing connection #{key}"
    connection.close
  rescue StandardError => e
    Fleck.logger.error e.inspect
  end
  @connections.clear

  true
end