Skip to content

Commit

Permalink
Merge 4ebb946 into 268f577
Browse files Browse the repository at this point in the history
  • Loading branch information
mastak committed Apr 11, 2018
2 parents 268f577 + 4ebb946 commit b07a4a6
Showing 1 changed file with 25 additions and 7 deletions.
32 changes: 25 additions & 7 deletions fluent/handler.py
Original file line number Diff line number Diff line change
Expand Up @@ -192,18 +192,36 @@ def __init__(self,
**kwargs):

self.tag = tag
self.sender = self.getSenderInstance(tag,
host=host, port=port,
timeout=timeout, verbose=verbose,
buffer_overflow_handler=buffer_overflow_handler,
msgpack_kwargs=msgpack_kwargs,
nanosecond_precision=nanosecond_precision,
**kwargs)
self._host = host
self._port = port
self._timeout = timeout
self._verbose = verbose
self._buffer_overflow_handler = buffer_overflow_handler
self._msgpack_kwargs = msgpack_kwargs
self._nanosecond_precision = nanosecond_precision
self._kwargs = kwargs
self._sender = None
logging.Handler.__init__(self)

def getSenderClass(self):
return sender.FluentSender

@property
def sender(self):
if self._sender is None:
self._sender = self.getSenderInstance(
tag=self.tag,
host=self._host,
port=self._port,
timeout=self._timeout,
verbose=self._verbose,
buffer_overflow_handler=self._buffer_overflow_handler,
msgpack_kwargs=self._msgpack_kwargs,
nanosecond_precision=self._nanosecond_precision,
**self._kwargs
)
return self._sender

def getSenderInstance(self, tag, host, port, timeout, verbose,
buffer_overflow_handler, msgpack_kwargs,
nanosecond_precision, **kwargs):
Expand Down

0 comments on commit b07a4a6

Please sign in to comment.