Commit 7f8b9a8b authored by Ignacio Corderi's avatar Ignacio Corderi
Browse files

Pull connection_id from initial handshake

parent 1b380c55

kinetic/baseclient.py

+2 −1
Original line number Diff line number Diff line
@@ -128,7 +128,6 @@ class BaseClient(object): 
            self._socket.settimeout(self.socket_timeout)



            self._sequence = itertools.count()

            self.connection_id = int(time.time())

            self._closed = False

        except:

            self._socket = None
@@ -148,6 +147,8 @@ class BaseClient(object): 
        elif (cmd.status.code != messages.Command.Status.SUCCESS):

            raise KineticMessageException(cmd.status)



        self.connection_id = cmd.header.connectionID



        self.config = cmd.body.getLog.configuration

        self.limits = cmd.body.getLog.limits