Class: Droonga::InternalFluentMessageReceiver

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

Instance Method Summary collapse

Constructor Details

#initialize(loop, host, &on_message) ⇒ InternalFluentMessageReceiver

Returns a new instance of InternalFluentMessageReceiver.



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

def initialize(loop, host, &on_message)
  @loop = loop
  @host = host
  @on_message = on_message
end

Instance Method Details

#shutdown ⇒ Object 



41
42
43
44
45
46
47
 
# File 'lib/droonga/internal_fluent_message_receiver.rb', line 41

def shutdown
  logger.trace("shutdown: start")
  shutdown_message_receiver
  shutdown_heartbeat_socket
  shutdown_listen_socket
  logger.trace("shutdown: done")
end

#start ⇒ Object 



31
32
33
34
35
36
37
38
39
 
# File 'lib/droonga/internal_fluent_message_receiver.rb', line 31

def start
  logger.trace("start: start")
  start_listen_socket
  start_heartbeat_socket
  start_message_receiver
  logger.trace("start: done")

  [@host, @port]
end