celery-client - npm Package Compare versions

Comparing version 0.1.2 to 0.1.3

celery-client.js

@@ -65,3 +65,3 @@ 'use strict';
 
-Client.prototype.putTask = function(task, args, kwargs, taskOptions, callback, onResultCallback) {
+Client.prototype.putTask = function(name, args, kwargs, taskOptions, callback, onResultCallback) {
   var self = this;
@@ -77,3 +77,3 @@
   self._backendHandler.onResult(mergedTaskOptions.id, onResultCallback || nope);
-  self._brokerHandler.putTask(task, args, kwargs, mergedTaskOptions, callback || nope);
+  self._brokerHandler.putTask(name, args, kwargs, mergedTaskOptions, callback || nope);
 };
@@ -80,0 +80,0 @@

handlers/redisHandler.js

@@ -25,3 +25,4 @@ 'use strict';
   };
-  var body = JSON.stringify([args, kwargs, embed]);
+  var message = JSON.stringify([args, kwargs, embed])
+  var body = new Buffer(message).toString('base64');
 
@@ -45,5 +46,7 @@ var message = {
       ],
-      'origin'   : taskOptions.origin,            // Senders name
+      'origin': taskOptions.origin,               // Senders name
+      'extra' : taskOptions.extra,
     },
     'properties': {
+      'body_encoding' : 'base64',                 // [Fixed value] Body encoding
       'priority'      : taskOptions.priority,     // Task priority
@@ -60,3 +63,3 @@ 'correlation_id': taskOptions.id,           // Same to `headers.id`
     'content-type'    : 'application/json',       // [Fixed value] Content type
-    'content-encoding': 'utf-8'                   // [Fixed value] Content encoding
+    'content-encoding': 'utf-8',                  // [Fixed value] Content encoding
   };
@@ -88,6 +91,6 @@
 
-RedisHandler.prototype.putTask = function(task, args, kwargs, taskOptions, callback) {
+RedisHandler.prototype.putTask = function(name, args, kwargs, taskOptions, callback) {
   var self = this;
 
-  var message = self.createMessage(task, args, kwargs, taskOptions);
+  var message = self.createMessage(name, args, kwargs, taskOptions);
 
@@ -147,3 +150,3 @@ var targetQueue = message.properties.delivery_info.routing_key;
       result[i] = JSON.parse(result[i]);
-      result[i].body = result[i].body ? JSON.parse(result[i].body) : null;
+      result[i].body = JSON.parse(new Buffer(result[i].body, 'base64').toString());
     }
@@ -169,3 +172,3 @@
         var t = JSON.parse(taskMap[taskId])[0];
-        t.body = t.body ? JSON.parse(t.body) : null;
+        t.body = JSON.parse(new Buffer(t.body, 'base64').toString());
 
@@ -172,0 +175,0 @@ result.push(t);

package.json

 {
   "name": "celery-client",
-  "version": "0.1.2",
+  "version": "0.1.3",
   "description": "A client for Celery",
@@ -5,0 +5,0 @@ "main": "celery-client.js",

No alert changes

Improved metrics

Total package byte prevSize

13194

increased by1.52%

Lines of code

228

increased by1.33%

No dependency changes