diff --git a/src/spawn.js b/src/spawn.js index 6c86399..cdca4ed 100644 --- a/src/spawn.js +++ b/src/spawn.js @@ -11,7 +11,6 @@ export default function spawn(worker, tube, payload, options = {}) { if (options.timeout !== undefined) { timeout = options.timeout; - delete options.timeout; } if (timeout < 3000) { @@ -20,20 +19,16 @@ export default function spawn(worker, tube, payload, options = {}) { if (options.delay !== undefined) { delay = options.delay; - delete options.delay; } if (options.priority !== undefined) { priority = options.priority; - delete options.priority; } - options.payload = payload; - tube = worker.tube(tube); return tube - .command('put', priority, delay / 1000, timeout / 1000, JSON.stringify(options)) + .command('put', priority, delay / 1000, timeout / 1000, JSON.stringify(payload)) .then(function (id) { tube.debug('spawned job: ' + id); return new Job(worker, tube, id); diff --git a/test/unit/spawn.test.js b/test/unit/spawn.test.js index 0194e7a..f25124a 100644 --- a/test/unit/spawn.test.js +++ b/test/unit/spawn.test.js @@ -34,9 +34,7 @@ describe('spawn', function () { actual = spawn(worker, tube, values); expect(worker.tube).to.have.been.calledWith(tube); - expect(tube.command).to.have.been.calledWith('put', 1000, 0, 600, JSON.stringify({ - payload: values - })); + expect(tube.command).to.have.been.calledWith('put', 1000, 0, 600, JSON.stringify(values)); return actual.then(function (job) { expect(job).to.be.an.instanceOf(Job);