diff options
| author | Andrew Donald Kennedy <grkvlt@apache.org> | 2010-10-03 16:00:24 +0000 |
|---|---|---|
| committer | Andrew Donald Kennedy <grkvlt@apache.org> | 2010-10-03 16:00:24 +0000 |
| commit | a81b0113c7384cd8e9f9d0b4eab069718ade6471 (patch) | |
| tree | d0e87e34459e4356165c02546568d16fafe5b89b /java/client | |
| parent | d1c794dc50ca9beb5ed59a8807c3c9517b9c61a1 (diff) | |
| download | qpid-python-a81b0113c7384cd8e9f9d0b4eab069718ade6471.tar.gz | |
QPID-2835 Implement CON Operational Logging on 0-10
Committed patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003984 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java index 2ee0a86e7c..adfd178ec3 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java @@ -23,7 +23,9 @@ package org.apache.qpid.client; import java.io.IOException; import java.util.ArrayList; +import java.util.HashMap; import java.util.List; +import java.util.Map; import javax.jms.ExceptionListener; import javax.jms.JMSException; @@ -159,7 +161,6 @@ public class AMQConnectionDelegate_0_10 implements AMQConnectionDelegate, Connec ConnectionSettings conSettings = new ConnectionSettings(); retriveConnectionSettings(conSettings,brokerDetail); - _qpidConnection.connect(conSettings); _conn._connected = true; @@ -371,6 +372,17 @@ public class AMQConnectionDelegate_0_10 implements AMQConnectionDelegate, Connec conSettings.setVerifyHostname(brokerDetail.getBooleanProperty(BrokerDetails.OPTIONS_SSL_VERIFY_HOSTNAME)); + // Pass client name from connection URL + Map<String, Object> clientProps = new HashMap<String, Object>(); + try + { + clientProps.put("clientName", _conn.getClientID()); + conSettings.setClientProperties(clientProps); + } + catch (JMSException e) + { + // Ignore + } if (brokerDetail.getProperty(BrokerDetails.OPTIONS_TCP_NO_DELAY) != null) { |