Add option to pass a codec engine to the client

client-pool.js

@@ -19,6 +19,8 @@ function ClientPool(options) {
     authKey: this.authKey
   };
 
+  clientConnectOptions.codecEngine = options.codecEngine || null
+
   this._handleClientError = (event) => {
     this.emit('error', event);
   };

cluster-broker-client.js

@@ -14,6 +14,7 @@ function ClusterBrokerClient(broker, options) {
   this.mappingEngine = options.mappingEngine || 'skeletonRendezvous';
   this.clientPoolSize = options.clientPoolSize || 1;
   this.isReady = false;
+  this.codecEngine = options.codecEngine || null;
 
   if (this.mappingEngine === 'skeletonRendezvous') {
     this.mapper = new SkeletonRendezvousMapper(options.mappingEngineOptions);
@@ -67,7 +68,8 @@ ClusterBrokerClient.prototype.setBrokers = function (sccBrokerURIList) {
     let clientPool = new ClientPool({
       clientCount: this.clientPoolSize,
       targetURI: clientURI,
-      authKey: this.authKey
+      authKey: this.authKey,
+      codecEngine: this.codecEngine
     });
     brokerClientMap[clientURI] = clientPool;
     this.sccBrokerClientPools[clientURI] = clientPool;

index.js

@@ -17,6 +17,7 @@ module.exports.attach = function (broker, options) {
     authKey: authKey,
     mappingEngine: options.mappingEngine,
     clientPoolSize: options.clientPoolSize,
+    codecEngine: options.codecEngine,
   });
 
   let retryDelay = options.brokerRetryDelay || DEFAULT_RETRY_DELAY;