Support msgpack_kwargs argument in FluentHandler. ref fluent#89

repeatedly · repeatedly · commit c6b72ec8cb5e · 2017-08-23T16:08:45.000+09:00
diff --git a/fluent/handler.py b/fluent/handler.py
@@ -137,13 +137,15 @@ def __init__(self,
                  timeout=3.0,
                  verbose=False,
                  buffer_overflow_handler=None,
+                 msgpack_kwargs=None,
                  nanosecond_precision=False):
 
         self.tag = tag
         self.sender = sender.FluentSender(tag,
                                           host=host, port=port,
                                           timeout=timeout, verbose=verbose,
                                           buffer_overflow_handler=buffer_overflow_handler,
+                                          msgpack_kwargs=msgpack_kwargs,
                                           nanosecond_precision=nanosecond_precision)
         logging.Handler.__init__(self)
 
