Class: Droonga::FluentMessageSender
- Inherits:
-
Object
- Object
- Droonga::FluentMessageSender
- Includes:
- Loggable
- Defined in:
- lib/droonga/fluent_message_sender.rb
Instance Method Summary collapse
-
#initialize(loop, host, port, options = {}) ⇒ FluentMessageSender
constructor
A new instance of FluentMessageSender.
- #resume ⇒ Object
- #send(tag, data) ⇒ Object
- #shutdown ⇒ Object
- #start ⇒ Object
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, ={}) @loop = loop @host = host @port = port @socket = nil @packer = MessagePackPacker.new @buffering = [:buffering] end |
Instance Method Details
#resume ⇒ Object
60 61 62 |
# File 'lib/droonga/fluent_message_sender.rb', line 60 def resume connect unless connected? end |
#send(tag, data) ⇒ Object
52 53 54 55 56 57 58 |
# File 'lib/droonga/fluent_message_sender.rb', line 52 def send(tag, data) logger.trace("send: start") = (tag, data) connect unless connected? @socket.write() 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 |