def METHOD_NAME(self):
    self.callback = None
    if self.unreg is not None:
        unreg = self.unreg
        self.unreg = None
        try:
            yield unreg.unsubscribe()
        except TransportLost:
            pass
        except Exception as e:
            log.err(e, 'When unsubscribing MQ connection ' + str(unreg))