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 | a5b1a1073e2596da8b5fbcd24769aec87107d212 (patch) | |
| tree | 66ae04f95841345d6bbd06a1fb303c27ece65902 /qpid/java/client | |
| parent | 98147863bc1e7816eedf6c957d96390ae35ebc60 (diff) | |
| download | qpid-python-a5b1a1073e2596da8b5fbcd24769aec87107d212.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@1003984 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java index 2ee0a86e7c..adfd178ec3 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java +++ b/qpid/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) { |