def _connect(self, cleanStart=True):
ack = CONNACK()<EOL>ack.session = False<EOL>ack.resultCode = <NUM_LIT:0><EOL>ack.encode()<EOL>self.protocol.connect("<STR_LIT>", keepalive=<NUM_LIT:0>, cleanStart=cleanStart, version=v31)<EOL>self.transport.clear()<EOL>self.protocol.dataReceived(ack.encoded)<EOL>
Go to connected state