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_gracefully ⇒ Object 



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

def shutdown_gracefully
  logger.trace("shutdown_gracefully: start")
  shutdown_heartbeat_socket
  shutdown_listen_socket
  shutdown_message_receiver_gracefully do
    yield
    logger.trace("shutdown_gracefully: done")
  end
end

#shutdown_immediately ⇒ Object 



51
52
53
54
55
56
57
 
# File 'lib/droonga/internal_fluent_message_receiver.rb', line 51

def shutdown_immediately
  logger.trace("shutdown_immediately: start")
  shutdown_heartbeat_socket
  shutdown_listen_socket
  shutdown_message_receiver_immediately
  logger.trace("shutdown_immediately: 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