fixed race condition

Author: kzk

fluent/sender.py

@@ -41,7 +41,6 @@ def __init__(self,
 
         self.socket = None
         self.pendings = None
-        self.packer = msgpack.Packer()
         self.lock = threading.Lock()
 
         try:
@@ -66,7 +65,7 @@ def _make_packet(self, label, timestamp, data):
         packet = (tag, timestamp, data)
         if self.verbose:
             print(packet)
-        return self.packer.pack(packet)
+        return msgpack.packb(packet)
 
     def _send(self, bytes_):
         self.lock.acquire()