def setUp(self):
self.transport = proto_helpers.StringTransportWithDisconnection()<EOL>self.clock     = task.Clock()<EOL>MQTTBaseProtocol.callLater = self.clock.callLater<EOL>self.factory   = MQTTFactory(MQTTFactory.PUBLISHER | MQTTFactory.SUBSCRIBER)<EOL>self._rebuild()<EOL>self.disconnected = <NUM_LIT:0><EOL>
Set up a connencted state