environment/lib/python2.7/site-packages/IPython/parallel/controller/hub.py
def dispatch_monitor_traffic(self, msg):
        """all ME and Task queue messages come through here, as well as
        IOPub traffic."""
        self.log.debug("monitor traffic: %r", msg[0])
        switch = msg[0]
        try:
            idents, msg = self.session.feed_identities(msg[1:])
        except ValueError:
            idents=[]
        if not idents:
            self.log.error("Monitor message without topic: %r", msg)
            return
        handler = self.monitor_handlers.get(switch, None)
        if handler is not None:
            handler(idents, msg)
        else:
            self.log.error("Unrecognized monitor topic: %r", switch)
def dispatch_monitor_traffic(self, msg):
        self.log.debug("monitor traffic: %r", msg[0])
        switch = msg[0]
        try:
            idents, msg = self.session.feed_identities(msg[1:])
        except ValueError:
            idents=[]
        if not idents:
            self.log.error("Monitor message without topic: %r", msg)
            return
        handler = self.monitor_handlers.get(switch, None)
        if handler is not None:
            handler(idents, msg)
        else:
            self.log.error("Unrecognized monitor topic: %r", switch)
def dispatch_monitor_traffic ( self , msg ) : self . log . debug ( "monitor traffic: %r" , msg [ 0 ] ) switch = msg [ 0 ] try : idents , msg = self . session . feed_identities ( msg [ 1 : ] ) except ValueError : idents = [ ] if not idents : self . log . error ( "Monitor message without topic: %r" , msg ) return handler = self . monitor_handlers . get ( switch , None ) if handler is not None : handler ( idents , msg ) else : self . log . error ( "Unrecognized monitor topic: %r" , switch )
all ME and Task queue messages come through here, as well as
        IOPub traffic.
all ME and Task queue messages come through here as well as IOPub traffic .