[NEW] Added option for maxControlLineSize, by default it is 1024 byte…

…s to match server default.
nats-io · Oct 24, 2017 · b497fc3 · b497fc3
1 parent cc52314
commit b497fc3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/lib/nats.js b/lib/nats.js
@@ -21,7 +21,7 @@ var net = require('net'),
 /**
  * Constants
  */
-var VERSION = '0.7.24',
+var VERSION = '0.7.26',
 
     DEFAULT_PORT = 4222,
     DEFAULT_PRE = 'nats://localhost:',
@@ -214,6 +214,7 @@ Client.prototype.parseOptions = function(opts) {
         'encoding': 'utf8',
         'tls': false,
         'waitOnFirstConnect': false,
+        'maxControlLineSize': MAX_CONTROL_LINE_SIZE
     };
 
     if (undefined === opts) {
@@ -252,6 +253,7 @@ Client.prototype.parseOptions = function(opts) {
         this.assignOption(opts, 'waitOnFirstConnect');
         this.assignOption(opts, 'json');
         this.assignOption(opts, 'preserveBuffers');
+        this.assignOption(opts, 'maxControlLineSize');
     }
 
     var client = this;
@@ -764,7 +766,7 @@ Client.prototype.processInbound = function() {
             case AWAITING_CONTROL:
                 // Regex only works on strings, so convert once to be more efficient.
                 // Long term answer is a hand rolled parser, not regex.
-                var buf = client.inbound.toString('binary', 0, MAX_CONTROL_LINE_SIZE);
+                var buf = client.inbound.toString('binary', 0, client.options.maxControlLineSize);
                 if ((m = MSG.exec(buf)) !== null) {
                     client.payload = {
                         subj: m[1],

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "nats",
-  "version": "0.7.24",
+  "version": "0.7.26",
   "description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system",
   "keywords": [
     "nats",