Class: Droonga::Forwarder

Inherits:
Object
  • Object
show all
Includes:
Loggable
Defined in:
lib/droonga/forwarder.rb

Instance Method Summary collapse

Constructor Details

#initialize(loop) ⇒ Forwarder

Returns a new instance of Forwarder.



26
27
28
29
 
# File 'lib/droonga/forwarder.rb', line 26

def initialize(loop)
  @loop = loop
  @senders = {}
end

Instance Method Details

#forward(message, destination) ⇒ Object 



44
45
46
47
48
49
50
51
 
# File 'lib/droonga/forwarder.rb', line 44

def forward(message, destination)
  logger.trace("forward: start")
  command = destination["type"]
  receiver = destination["to"]
  arguments = destination["arguments"]
  output(receiver, message, command, arguments)
  logger.trace("forward: done")
end

#shutdown ⇒ Object 



36
37
38
39
40
41
42
 
# File 'lib/droonga/forwarder.rb', line 36

def shutdown
  logger.trace("shutdown: start")
  @senders.each_value do |sender|
    sender.shutdown
  end
  logger.trace("shutdown: done")
end

#start ⇒ Object 



31
32
33
34
 
# File 'lib/droonga/forwarder.rb', line 31

def start
  logger.trace("start: start")
  logger.trace("start: done")
end