Add data in queue through API

Allan_Zimmermann · October 25, 2024, 8:50am

current ( but soon to be old ) api

new ( still in beta but will soon be the current ) api:

skadefro/nodetest/blob/b6dbce9e325de7378b757e526696fb7881738c03/test.js#L318


      
              const delete_many_query_result = client.delete_many({ collectionname: 'entities', query: '{"name":"test insert many from nodejs"}' });
              console.log("delete_many success", delete_many_query_result);
          }
          
          let nextrun = new Date();
          nextrun.setSeconds(nextrun.getSeconds() + 60);
          nextrun = undefined;
          let files1 = [];
          files1.push(filepath);
          if(test_async) {
              let push_workitem_async_result = await client.push_workitem_async({ wiq: "rustqueue", name: "node test async", nextrun, files: files1});
              console.log("push_workitem async success", push_workitem_async_result);
          
              let pop_workitem_async_result = await client.pop_workitem_async({ wiq: "rustqueue" });
              console.log("pop_workitem async success", pop_workitem_async_result);
          
              console.log("set pop_workitem_async_result.state = successful");
              pop_workitem_async_result.state = "successful";
              const update_workitem_async_result = await client.update_workitem_async({ workitem: pop_workitem_async_result });
              console.log("update_workitem async success", update_workitem_async_result);