Commit e5ac8c76 authored by Paul Dardeau's avatar Paul Dardeau
Browse files

Added support for no_ack sends

parent 4cc7039a

kinetic/threadedclient.py

+2 −2
Original line number Diff line number Diff line
@@ -59,8 +59,8 @@ class ThreadedClient(BaseAsync): 
        self.writer_thread.join()

        self.thread.join()



    def sendAsync(self, header, value, onSuccess, onError):

        self.queue.put((header, value, onSuccess, onError))

    def sendAsync(self, header, value, onSuccess, onError, no_ack=False):

        self.queue.put((header, value, onSuccess, onError, no_ack))



    def _writer(self):

        while self.isConnected and not self.faulted: