expose serverProperties in the connection object

amqp-node · Oct 8, 2018 · 0f77300 · 0f77300
1 parent 13741dd
commit 0f77300
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/lib/connection.js b/lib/connection.js
@@ -205,6 +205,7 @@ C.open = function(allFields, openCallback0) {
                          allFields.mechanism)));
       return;
     }
+    self.serverProperties = start.fields.serverProperties;
     send(defs.ConnectionStartOk);
     wait(afterStartOk);
   }

diff --git a/test/connect.js b/test/connect.js
@@ -79,6 +79,17 @@ suite("Connect API", function() {
     connect(u, {}, kCallback(fail(done), succeed(done)));
   });
 
+  test("serverProperties", function(done) {
+    var url = require('url');
+    var parts = url.parse(URL, true);
+    var config = parts.query || {};
+    connect(config, {}, function(err, connection) {
+      if (err) { return done(err); }
+      assert.equal(connection.serverProperties.product, 'RabbitMQ');
+      done();
+    });
+  });
+
   test("using custom heartbeat option", function(done) {
     var url = require('url');
     var parts = url.parse(URL, true);