

def gotMessage(self, stream, message):
    log.msg(('Got XMPP message %s' % message.toXml()))
    try:
        d = stream._pending[message['id']]
        d.callback(message)
        del stream._pending[message['id']]
    except KeyError:
        self.gotEvent(message)

dataset/ETHPy150Open selfsk/nodeset.core/src/nodeset/core/pubsub/agent.py XmppAgent.gotMessage/original