platypush/bus/__init__.py
def poll(self):
        """
        Reads messages from the bus until either stop event message or KeyboardInterrupt
        """
        if not self.on_message:
            logger.warning('No message handlers installed, cannot poll')
            return

        while not self.should_stop():
            msg = self.get()
            if msg is None:
                continue

            timestamp = msg.timestamp if hasattr(msg, 'timestamp') else msg.get('timestamp')
            if timestamp and time.time() - timestamp > self._MSG_EXPIRY_TIMEOUT:
                logger.debug('{} seconds old message on the bus expired, ignoring it: {}'.
                             format(int(time.time()-msg.timestamp), msg))
                continue

            threading.Thread(target=self._msg_executor(msg)).start()

        logger.info('Bus service stopped')

        Reads messages from the bus until either stop event message or KeyboardInterrupt
        
Reads messages from the bus until either stop event message or KeyboardInterrupt
Reads messages from the bus until either stop event message or KeyboardInterrupt
def poll(self):
        if not self.on_message:
            logger.warning('No message handlers installed, cannot poll')
            return
        while not self.should_stop():
            msg = self.get()
            if msg is None:
                continue
            timestamp = msg.timestamp if hasattr(msg, 'timestamp') else msg.get('timestamp')
            if timestamp and time.time() - timestamp > self._MSG_EXPIRY_TIMEOUT:
                logger.debug('{} seconds old message on the bus expired, ignoring it: {}'.
                             format(int(time.time()-msg.timestamp), msg))
                continue
            threading.Thread(target=self._msg_executor(msg)).start()
        logger.info('Bus service stopped')
def poll ( self ) : if not self . on_message : logger . warning ( 'No message handlers installed, cannot poll' ) return while not self . should_stop ( ) : msg = self . get ( ) if msg is None : continue timestamp = msg . timestamp if hasattr ( msg , 'timestamp' ) else msg . get ( 'timestamp' ) if timestamp and time . time ( ) - timestamp > self . _MSG_EXPIRY_TIMEOUT : logger . debug ( '{} seconds old message on the bus expired, ignoring it: {}' . format ( int ( time . time ( ) - msg . timestamp ) , msg ) ) continue threading . Thread ( target = self . _msg_executor ( msg ) ) . start ( ) logger . info ( 'Bus service stopped' )
Reads messages from the bus until either stop event message or KeyboardInterrupt
Reads messages from the bus until either stop event message or KeyboardInterrupt
"""
        Reads messages from the bus until either stop event message or KeyboardInterrupt
        """
self