gearman-node-bda - npm Package Compare versions

Comparing version 0.9.6 to 0.9.7

lib/gearmanode/client.js

		@@ -152,3 +152,3 @@ // Copyright 2013 The GearmaNode Library Authors. All Rights Reserved.
		if (err instanceof Error) {
		Client.logger.log('warn', 'failed to submit job, server=%s, error:', jobServer.getUid(), err);
		Client.logger.log('warn', 'failed to submit job, server=%s, error=%s', jobServer.getUid(), err.stack);
		tryToSend();
		@@ -159,3 +159,3 @@ } else {
		process.nextTick(function() { job.emit('submited'); });
		Client.logger.log('debug', 'job submited, name=%s, unique=%s', job.name, job.unique);
		Client.logger.log('debug', 'job submited, name=%s, unique=%s, jobServerUid=%s', job.name, job.unique, job.jobServerUid);
		}
		@@ -162,0 +162,0 @@ }

lib/gearmanode/job-server.js

		@@ -224,2 +224,3 @@ // Copyright 2013 The GearmaNode Library Authors. All Rights Reserved.
		this.send(packet);
		JobServer.logger.log('debug','echo back REQ, data=%s', data);
		}
		@@ -363,3 +364,3 @@
		case protocol.PACKET_TYPES.ERROR:
		JobServer.logger.log('warn', 'job server error, uid=%s, code=%s, msg=%s',
		JobServer.logger.log('error', 'job server error, uid=%s, code=%s, msg=%s',
		this.getUid(), parsedPacket[1], parsedPacket[2]);
		@@ -366,0 +367,0 @@

lib/gearmanode/worker.js

		@@ -116,2 +116,3 @@ // Copyright 2013 The GearmaNode Library Authors. All Rights Reserved.
		jobServer = this.jobServers[i];

		if (options.hasOwnProperty('timeout')) {
		@@ -122,5 +123,6 @@ jobServer.send(protocol.encodePacket(protocol.PACKET_TYPES.CAN_DO_TIMEOUT, [name, options['timeout']]));
		}

		Worker.logger.log('info', 'registered function name=%s on server uid=%s', name, jobServer.getUid());
		this._preSleep(jobServer);
		this.functions[name] = [callback, options];
		Worker.logger.log('info', 'registered function name=%s on server uid=%s', name, jobServer.getUid());
		}
		@@ -239,2 +241,3 @@ }
		var jobOpts = { handle: parsedPacket[1], name: parsedPacket[2], jobServerUid: jobServer.getUid() };
		Worker.logger.log("debug", "job assign, handle=%s, name=%s", jobOpts.handle, jobOpts.name);
		if (packetType === protocol.PACKET_TYPES.JOB_ASSIGN) {
		@@ -241,0 +244,0 @@ jobOpts.payload = parsedPacket[3];

package.json

		{
		"name": "gearman-node-bda",
		"version": "0.9.6",
		"version": "0.9.7",
		"description": "Node.js library for the Gearman distributed job system with support for multiple servers",
		@@ -35,3 +35,3 @@ "keywords": [
		"dependencies": {
		"winston": ">=0.7.1"
		"winston": "^2.0.0"
		},
		@@ -38,0 +38,0 @@ "devDependencies": {

New alerts