def gotIq(self, stream, message):
            
        log.msg("Got IQ message - %s" % message.toXml())
        iq_id = message.getAttribute('id')
        
        log.msg("_pending %s" % stream._pending)
        try:
            d = stream._pending[iq_id]
            d.callback(message)#.addErrback(_errIq)
            
            del stream._pending[iq_id]
        except __HOLE__:
            pass
dataset/ETHPy150Open selfsk/nodeset.core/src/nodeset/core/pubsub/agent.py/XmppAgent.gotIq