add dateSeparator on index creation

This commit is contained in:
2016-08-22 11:11:57 -07:00
parent faeb705dee
commit 83f267a028

View File

@@ -19,6 +19,7 @@ export default class Esqueue extends events.EventEmitter {
interval: constants.DEFAULT_SETTING_INTERVAL, interval: constants.DEFAULT_SETTING_INTERVAL,
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,
}, omit(options, [ 'client' ])); }, omit(options, [ 'client' ]));
this.client = createClient(options.client || {}); this.client = createClient(options.client || {});
@@ -38,7 +39,7 @@ export default class Esqueue extends events.EventEmitter {
} }
addJob(type, payload, opts = {}) { addJob(type, payload, opts = {}) {
const timestamp = indexTimestamp(this.settings.interval); const timestamp = indexTimestamp(this.settings.interval, this.settings.dateSeparator);
const index = `${this.index}-${timestamp}`; const index = `${this.index}-${timestamp}`;
const defaults = { const defaults = {
timeout: this.settings.timeout, timeout: this.settings.timeout,