def onDisconnection(self, reason):
log.debug("<STR_LIT>", r=reason)<EOL>self.whenConnected().addCallback(self.connectToBroker)<EOL>
get notfied of disconnections
and get a deferred for a new protocol object (next retry)