w33ble/elastiq
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

replace lodash methods with local helpers

Browse Source
This commit is contained in:
Joe Fleming
2017-02-28 14:48:23 -07:00
parent 64c1c90337
commit bbd82a1de1
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/index.js
View File

@@ -1,10 +1,10 @@
import events from 'events'; import events from 'events';
import omit from 'lodash.omit';
import Job from './job.js'; import Job from './job.js';
import Worker from './worker.js'; import Worker from './worker.js';
import constants from './constants'; import constants from './constants';
import createClient from './helpers/create_client'; import createClient from './helpers/create_client';
import indexTimestamp from './helpers/index_timestamp'; import indexTimestamp from './helpers/index_timestamp';
import objectOmit from './helpers/object_omit';
import logger from './helpers/logger'; import logger from './helpers/logger';
const debug = logger('esqueue:queue'); const debug = logger('esqueue:queue');
@@ -20,7 +20,7 @@ export default class Esqueue extends events.EventEmitter {
timeout: constants.DEFAULT_SETTING_TIMEOUT, timeout: constants.DEFAULT_SETTING_TIMEOUT,
doctype: constants.DEFAULT_SETTING_DOCTYPE, doctype: constants.DEFAULT_SETTING_DOCTYPE,
dateSeparator: constants.DEFAULT_SETTING_DATE_SEPARATOR, dateSeparator: constants.DEFAULT_SETTING_DATE_SEPARATOR,
}, omit(options, [ 'client' ])); }, objectOmit(options, [ 'client' ]));
this.client = createClient(options.client || {}); this.client = createClient(options.client || {});
this._workers = []; this._workers = [];

2
src/job.js
View File

@@ -1,9 +1,9 @@
import events from 'events'; import events from 'events';
import isPlainObject from 'lodash.isplainobject';
import Puid from 'puid'; import Puid from 'puid';
import contstants from './constants'; import contstants from './constants';
import logger from './helpers/logger'; import logger from './helpers/logger';
import createIndex from './helpers/create_index'; import createIndex from './helpers/create_index';
import isPlainObject from './helpers/is_plain_object';
const debug = logger('esqueue:job'); const debug = logger('esqueue:job');
const puid = new Puid(); const puid = new Puid();