Skip to content

Commit 40c7571

Browse files
author
Vlad Ionescu
committed
adding Connection.getClientProperties()
1 parent 393072f commit 40c7571

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

src/com/rabbitmq/client/Connection.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
package com.rabbitmq.client;
3232

3333
import java.io.IOException;
34+
import java.util.Map;
3435

3536
/**
3637
* Public API: Interface to an AMQ connection. See the see the <a href="http://www.amqp.org/">spec</a> for details.
@@ -89,6 +90,13 @@ public interface Connection extends ShutdownNotifier { // rename to AMQPConnecti
8990
*/
9091
int getHeartbeat();
9192

93+
/**
94+
* Get the map of client properties sent to the server
95+
*
96+
* @return map of client properties
97+
*/
98+
Map<String, Object> getClientProperties();
99+
92100
/**
93101
* Retrieve the known hosts.
94102
* @return an array of addresses for all hosts that came back in the initial {@link com.rabbitmq.client.AMQP.Connection.OpenOk} open-ok method

src/com/rabbitmq/client/impl/AMQConnection.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -364,6 +364,10 @@ public void setHeartbeat(int heartbeat) {
364364
}
365365
}
366366

367+
public Map<String, Object> getClientProperties() {
368+
return _clientProperties;
369+
}
370+
367371
/**
368372
* Protected API - retrieve the current ExceptionHandler
369373
*/

0 commit comments

Comments
 (0)