set binary encoding to avro

moleculerjs · Apr 4, 2017 · c1aa9cc · c1aa9cc
1 parent 66c5c07
commit c1aa9cc
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/benchmark/perf-runner.js b/benchmark/perf-runner.js
@@ -5,7 +5,7 @@ const v8 = require('v8-natives');
 let ServiceBroker = require("../src/service-broker");
 let Context = require("../src/context");
 let Transporters = require("../src/transporters");
-let Serializer = require("../src/serializers/pson");
+let Serializer = require("../src/serializers/avro");
 
 let { generateToken, json2String } = require("../src/utils");
 let Promise	= require("bluebird");
@@ -17,7 +17,7 @@ function createBrokers(Transporter, opts) {
 		requestTimeout: 0,
 		//logger: console,
 		//logLevel: "debug",
-		//serializer: new Serializer(),
+		serializer: new Serializer(),
 		nodeID: "node-1",
 
 	});
@@ -27,7 +27,7 @@ function createBrokers(Transporter, opts) {
 		//requestTimeout: 0,
 		//logger: console,
 		//logLevel: "debug",
-		//serializer: new Serializer(),
+		serializer: new Serializer(),
 		nodeID: "node-2"
 	});
 

diff --git a/src/serializers/avro.js b/src/serializers/avro.js
@@ -116,7 +116,7 @@ class AvroSerializer extends BaseSerializer {
 	 */
 	serialize(obj, type) {
 		const t = schemas[type].toBuffer(obj);
-		return t.toString("hex");
+		return t.toString("binary");
 	}
 
 	/**
@@ -129,7 +129,7 @@ class AvroSerializer extends BaseSerializer {
 	 * @memberOf Serializer
 	 */
 	deserialize(str, type) {
-		const res = schemas[type].fromBuffer(Buffer.from(str, "hex"));
+		const res = schemas[type].fromBuffer(Buffer.from(str, "binary"));
 		return res;
 	}
 }