def queue(self, queue, message, params={}, uids=[]):
        """
        Queue a job in Rhumba
        """

        d = {
            'id': uuid.uuid1().get_hex(),
            'version': 1,
            'message': message,
            'params': params
        }

        ser = json.dumps(d)
        
        if uids:
            for uid in uids:
                path = '/dq/%s/%s' % (uid, queue)
                yield self._put_queue(path, ser)

        else:
            path = '/q/%s' % queue
            yield self._put_queue(path, ser)

        defer.returnValue(d['id'])
def queue ( self , queue , message , params = { } , uids = [ ] ) : d = { 'id' : uuid . uuid1 ( ) . get_hex ( ) , 'version' : 1 , 'message' : message , 'params' : params } ser = json . dumps ( d ) if uids : for uid in uids : path = '/dq/%s/%s' % ( uid , queue ) yield self . _put_queue ( path , ser ) else : path = '/q/%s' % queue yield self . _put_queue ( path , ser ) defer . returnValue ( d [ 'id' ] )
Queue a job in Rhumba