Skip to content

Commit 6ee18f2

Browse files
authored
Merge pull request #452 from jfromaniello/expose_serverProperties
expose serverProperties in the connection object
2 parents d98449b + 0f77300 commit 6ee18f2

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

lib/connection.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -205,6 +205,7 @@ C.open = function(allFields, openCallback0) {
205205
allFields.mechanism)));
206206
return;
207207
}
208+
self.serverProperties = start.fields.serverProperties;
208209
send(defs.ConnectionStartOk);
209210
wait(afterStartOk);
210211
}

test/connect.js

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,17 @@ suite("Connect API", function() {
7979
connect(u, {}, kCallback(fail(done), succeed(done)));
8080
});
8181

82+
test("serverProperties", function(done) {
83+
var url = require('url');
84+
var parts = url.parse(URL, true);
85+
var config = parts.query || {};
86+
connect(config, {}, function(err, connection) {
87+
if (err) { return done(err); }
88+
assert.equal(connection.serverProperties.product, 'RabbitMQ');
89+
done();
90+
});
91+
});
92+
8293
test("using custom heartbeat option", function(done) {
8394
var url = require('url');
8495
var parts = url.parse(URL, true);

0 commit comments

Comments
 (0)