Class: Droonga::FluentMessageSender

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

Instance Method Summary collapse

Constructor Details

#initialize(loop, host, port, options = {}) ⇒ FluentMessageSender

Returns a new instance of FluentMessageSender.



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

def initialize(loop, host, port, options={})
  @loop = loop
  @host = host
  @port = port
  @socket = nil
  @packer = MessagePackPacker.new
  @buffering = options[:buffering]
end

Instance Method Details

#resume ⇒ Object 



63
64
65
66
67
68
 
# File 'lib/droonga/fluent_message_sender.rb', line 63

def resume
  unless connected?
    logger.trace("resume: reconnect to #{target_node}")
    connect
  end
end

#send(tag, data) ⇒ Object 



52
53
54
55
56
57
58
59
60
61
 
# File 'lib/droonga/fluent_message_sender.rb', line 52

def send(tag, data)
  logger.trace("send: start")
  packed_fluent_message = create_packed_fluent_message(tag, data)
  unless connected?
    logger.trace("send: reconnect")
    connect
  end
  @socket.write(packed_fluent_message)
  logger.trace("send: done")
end

#shutdown ⇒ Object 



46
47
48
49
50
 
# File 'lib/droonga/fluent_message_sender.rb', line 46

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

#start ⇒ Object 



41
42
43
44
 
# File 'lib/droonga/fluent_message_sender.rb', line 41

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