npm install feathers-bee --save app.use('/bee', bee({ service: app.service('serviceToLog'), // add your service name: 'example' }));- service: The service to log
- name: Name of the Queue
- queue: Settings of the Queue
- paginate: The default pagenate stuff
The bee-queue events are implemented as custom feathers events
- Create a new job: call create at the bee service to create a new job
- Get a job: call get with a job id to get a job
- Find jobs: call find at the bee service to find the waiting jobs
- change type with params
Here's an example of a Feathers server that uses feathers-bee.
const feathers = require('feathers'); const rest = require('feathers-rest'); const socketio = require('feathers-socketio'); const handler = require('feathers-errors/handler'); const bodyParser = require('body-parser'); const memory = require('feathers-memory'); const bee = require('feathers-bee'); // Create a feathers instance. const app = feathers() .configure(socketio()) .configure(rest()) .use(bodyParser.json()) .use(bodyParser.urlencoded({extended: true})); // Create any service you like. app.use('/messages', memory({ paginate: { default: 2, max: 4 }, id:'_id' })); // Create bee service app.use('/bee', bee({ service: app.service('messages'), // add your service name: 'example', // name queue: {}, // queue settings paginate: { default: 2, max: 4 } })); // A basic error handler, just like Express app.use(handler()); // Start the server var server = app.listen(3030); server.on('listening', function () { console.log('Feathers running on 127.0.0.1:3030'); });Copyright (c) 2017
Licensed under the MIT license.