summaryrefslogtreecommitdiff
path: root/qpid/java/amqp-1-0-common/src
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-01-14 08:58:03 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-01-14 08:58:03 +0000
commit6dfbb79c9ce4835cc744c466e41bb1b42cee81c1 (patch)
treef341296e462617b4a80ec0e192f80224a438c405 /qpid/java/amqp-1-0-common/src
parentc9660933637b69a14ae870397a53b086a8d6ab85 (diff)
downloadqpid-python-6dfbb79c9ce4835cc744c466e41bb1b42cee81c1.tar.gz
QPID-5459 : Added configurable TLS parameters for AMQP 1.0 client (both TCP and WSS)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1557982 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/amqp-1-0-common/src')
-rw-r--r--qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java10
1 files changed, 9 insertions, 1 deletions
diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
index 1c80668856..9c93c1f0a5 100644
--- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
+++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
@@ -103,7 +103,7 @@ public class ConnectionEndpoint implements DescribedTypeConstructorRegistry.Sour
private UnsignedInteger _handleMax = UnsignedInteger.MAX_VALUE;
private ConnectionEventListener _connectionEventListener = ConnectionEventListener.DEFAULT;
private String _password;
- private final boolean _requiresSASLClient;
+ private boolean _requiresSASLClient;
private final boolean _requiresSASLServer;
@@ -140,6 +140,14 @@ public class ConnectionEndpoint implements DescribedTypeConstructorRegistry.Sour
_requiresSASLServer = false;
}
+ public void setPrincipal(Principal user)
+ {
+ if(_user == null)
+ {
+ _user = user;
+ _requiresSASLClient = user != null;
+ }
+ }
public synchronized void open()
{