We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 282acea commit cbec775Copy full SHA for cbec775
src/com/rabbitmq/client/impl/AMQConnection.java
@@ -145,6 +145,9 @@ public void ensureIsOpen()
145
/** Hosts retrieved from the connection.open-ok */
146
public Address[] _knownHosts;
147
148
+ /** Saved server properties field from connection.start */
149
+ public Map<String, Object> _serverProperties;
150
+
151
/** {@inheritDoc} */
152
public String getHost() {
153
return _frameHandler.getHost();
@@ -234,6 +237,8 @@ public void start(boolean insist)
234
237
try {
235
238
AMQP.Connection.Start connStart =
236
239
(AMQP.Connection.Start) connStartBlocker.getReply().getMethod();
240
241
+ _serverProperties = connStart.getServerProperties();
242
243
Version serverVersion =
244
new Version(connStart.getVersionMajor(),
0 commit comments