fix(SaslInitFrame): mechanism _must_ be an amqp symbol

noodlefrenzy · Oct 11, 2015 · b8c7e84 · b8c7e84
1 parent c95b741
commit b8c7e84
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/frames/sasl_frame.js b/lib/frames/sasl_frame.js
@@ -214,7 +214,8 @@ function SaslInit(options) {
     this.hostname = up.get(options, 2);
   } else {
     u.assertArguments(options, ['mechanism']);
-    this.mechanism = options.mechanism;
+    this.mechanism = (options.mechanism instanceof AMQPSymbol) ?
+      options.mechanism : new AMQPSymbol(options.mechanism);
     this.initialResponse = options.initialResponse;
     this.hostname = options.hostname;
   }