mirror of https://gitee.com/bigwinds/arangodb
23 lines
559 B
JavaScript
23 lines
559 B
JavaScript
'use strict';
|
|
const queues = require('@arangodb/foxx/queues');
|
|
const router = require('@arangodb/foxx/router')();
|
|
module.context.use(router);
|
|
|
|
router.post((req, res) => {
|
|
const body = req.body && req.body.length ? JSON.parse(req.body.toString()) : {};
|
|
const queue = queues.create('test_queue');
|
|
queue.push({
|
|
name: 'job',
|
|
mount: '/queue_test_mount'
|
|
}, {}, body || {});
|
|
});
|
|
|
|
router.delete((req, res) => {
|
|
const queue = queues.get('test_queue');
|
|
for (const job of queue.all()) {
|
|
queue.delete(job);
|
|
}
|
|
queues.delete('test_queue');
|
|
});
|
|
|