Class: Consumer::HandlerRegistry

Inherits:
Object
  • Object
show all
Includes:
Log::Dependency
Defined in:
lib/consumer/handler_registry.rb

Defined Under Namespace

Modules: LogText

Constant Summary collapse

Error = 
Class.new(RuntimeError)

Instance Method Summary collapse

Instance Method Details

#count ⇒ Object 



49
50
51
 
# File 'lib/consumer/handler_registry.rb', line 49

def count
  entries.count
end

#entries ⇒ Object 



45
46
47
 
# File 'lib/consumer/handler_registry.rb', line 45

def entries
  @entries ||= Set.new
end

#get(consumer) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/consumer/handler_registry.rb', line 23

def get(consumer)
  entries.map do |handler|
    if handler.is_a? Proc
      proc { |message_data|
        consumer.instance_exec(message_data, &handler)
      }
    else
      handler.build
    end
  end
end

#register(handler) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/consumer/handler_registry.rb', line 7

def register(handler)
  logger.trace { "Registering handler (Handler: #{LogText.handler(handler)})" }

  if registered? handler
    error_message = "Handler is already registered (Handler: #{LogText.handler(handler)})"
    logger.error { error_message }
    raise Error, error_message
  end

  entries << handler

  logger.debug { "Handler registered (Handler: #{LogText.handler(handler)})" }

  handler
end

#registered?(handler) ⇒ Boolean

Returns:

  • (Boolean) 


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

def registered?(handler)
  entries.any? do |entry|
    return true if handler == entry 

    next if entry.is_a?(Proc)

    handler === entry
  end
end