feat(vhosts): add vhosts specified in address to sasl init frame

lib/amqp_client.js

@@ -97,6 +97,8 @@ AMQPClient.prototype.connect = function(url) {
     self._defaultQueue = address.path.substr(1);
     self.policy.connect.options.hostname = address.host;
     var sasl = address.user ? new Sasl() : null;
+    if (!!sasl && !!address.vhost) sasl._remoteHostname = address.vhost;
+
     self._connection = self._newConnection();
     self._connection.on(Connection.Connected, function(c) {
       debug('connected');

lib/sasl.js

@@ -40,7 +40,7 @@ Sasl.prototype.headerReceived = function(header) {
   debug('Server SASL Version: ' + header.toString('hex') + ' vs ' + constants.saslVersion.toString('hex'));
   if (u.bufferEquals(header, constants.saslVersion)) {
     this.receivedHeader = true;
-  // Wait for mechanisms
+    // Wait for mechanisms
   } else {
     this.callback(new errors.MalformedHeaderError('Invalid SASL Header ' + header.toString('hex')));
   }
@@ -59,6 +59,8 @@ Sasl.prototype._processFrame = function(frame) {
         mechanism: new AMQPSymbol('PLAIN'),
         initialResponse: buf.get()
       });
+
+      if (!!this._remoteHostname) initFrame.hostname = this._remoteHostname;
       this.connection.sendFrame(initFrame);
     } else {
       throw new errors.NotImplementedError('Only supports SASL-PLAIN at the moment.');