examples/subscriber.py
def onDisconnection(self, reason):
        '''
        get notfied of disconnections
        and get a deferred for a new protocol object (next retry)
        '''
        log.debug("<Connection was lost !> <reason={r}>", r=reason)
        self.whenConnected().addCallback(self.connectToBroker)
def onDisconnection(self, reason):
        '''
        get notfied of disconnections
        and get a deferred for a new protocol object (next retry)
        '''
        log.debug("<Connection was lost !> <reason={r}>", r=reason)
        self.whenConnected().addCallback(self.connectToBroker)
def onDisconnection ( self , reason ) : log . debug ( "<Connection was lost !> <reason={r}>" , r = reason ) self . whenConnected ( ) . addCallback ( self . connectToBroker )
get notfied of disconnections
        and get a deferred for a new protocol object (next retry)
get notfied of disconnections and get a deferred for a new protocol object ( next retry )