1 files changed, 336 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSettings.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSettings.java
new file mode 100644
index 0000000000..08678b213b
--- /dev/null
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSettings.java
@@ -0,0 +1,336 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.transport;
+
+import java.util.Map;
+
+/**
+ * A ConnectionSettings object can only be associated with
+ * one Connection object. I have added an assertion that will
+ * throw an exception if it is used by more than on Connection
+ *
+ */
+public class ConnectionSettings
+{
+    String protocol = "tcp";
+    String host = "localhost";
+    String vhost;
+    String username = "guest";
+    String password = "guest";
+    int port = 5672;
+    boolean tcpNodelay = Boolean.getBoolean("amqj.tcp_nodelay");
+    int maxChannelCount = 32767;
+    int maxFrameSize = 65535;
+    int heartbeatInterval;
+    int readBufferSize = 65535;
+    int writeBufferSize = 65535;
+    long transportTimeout = 60000;
+    
+    // SSL props
+    boolean useSSL;
+    String keyStorePath = System.getProperty("javax.net.ssl.keyStore");
+    String keyStorePassword = System.getProperty("javax.net.ssl.keyStorePassword");
+    String keyStoreCertType = System.getProperty("qpid.ssl.keyStoreCertType","SunX509");;
+    String trustStoreCertType = System.getProperty("qpid.ssl.trustStoreCertType","SunX509");;
+    String trustStorePath = System.getProperty("javax.net.ssl.trustStore");;
+    String trustStorePassword = System.getProperty("javax.net.ssl.trustStorePassword");;
+    String certAlias;
+    boolean verifyHostname;
+    
+    // SASL props
+    String saslMechs = System.getProperty("qpid.sasl_mechs", "PLAIN");
+    String saslProtocol = System.getProperty("qpid.sasl_protocol", "AMQP");
+    String saslServerName = System.getProperty("qpid.sasl_server_name", "localhost");
+    boolean useSASLEncryption;
+   
+    private Map<String, Object> _clientProperties;
+    
+    public boolean isTcpNodelay()
+    {
+        return tcpNodelay;
+    }
+
+    public void setTcpNodelay(boolean tcpNodelay)
+    {
+        this.tcpNodelay = tcpNodelay;
+    }
+
+    public int getHeartbeatInterval()
+    {
+        return heartbeatInterval;
+    }
+
+    public void setHeartbeatInterval(int heartbeatInterval)
+    {
+        this.heartbeatInterval = heartbeatInterval;
+    }
+
+    public String getProtocol()
+    {
+        return protocol;
+    }
+
+    public void setProtocol(String protocol)
+    {
+        this.protocol = protocol;
+    }
+
+    public String getHost()
+    {
+        return host;
+    }
+
+    public void setHost(String host)
+    {
+        this.host = host;
+    }
+
+    public int getPort()
+    {
+        return port;
+    }
+
+    public void setPort(int port)
+    {
+        this.port = port;
+    }
+
+    public String getVhost()
+    {
+        return vhost;
+    }
+
+    public void setVhost(String vhost)
+    {
+        this.vhost = vhost;
+    }
+
+    public String getUsername()
+    {
+        return username;
+    }
+
+    public void setUsername(String username)
+    {
+        this.username = username;
+    }
+
+    public String getPassword()
+    {
+        return password;
+    }
+
+    public void setPassword(String password)
+    {
+        this.password = password;
+    }
+
+    public boolean isUseSSL()
+    {
+        return useSSL;
+    }
+
+    public void setUseSSL(boolean useSSL)
+    {
+        this.useSSL = useSSL;
+    }
+
+    public boolean isUseSASLEncryption()
+    {
+        return useSASLEncryption;
+    }
+
+    public void setUseSASLEncryption(boolean useSASLEncryption)
+    {
+        this.useSASLEncryption = useSASLEncryption;
+    }
+
+    public String getSaslMechs()
+    {
+        return saslMechs;
+    }
+
+    public void setSaslMechs(String saslMechs)
+    {
+        this.saslMechs = saslMechs;
+    }
+
+    public String getSaslProtocol()
+    {
+        return saslProtocol;
+    }
+
+    public void setSaslProtocol(String saslProtocol)
+    {
+        this.saslProtocol = saslProtocol;
+    }
+
+    public String getSaslServerName()
+    {
+        return saslServerName;
+    }
+
+    public void setSaslServerName(String saslServerName)
+    {
+        this.saslServerName = saslServerName;
+    }
+
+    public int getMaxChannelCount()
+    {
+        return maxChannelCount;
+    }
+
+    public void setMaxChannelCount(int maxChannelCount)
+    {
+        this.maxChannelCount = maxChannelCount;
+    }
+
+    public int getMaxFrameSize()
+    {
+        return maxFrameSize;
+    }
+
+    public void setMaxFrameSize(int maxFrameSize)
+    {
+        this.maxFrameSize = maxFrameSize;
+    }
+
+    public void setClientProperties(final Map<String, Object> clientProperties)
+    {
+        _clientProperties = clientProperties;
+    }
+
+    public Map<String, Object> getClientProperties()
+    {
+        return _clientProperties;
+    }
+    
+    public String getKeyStorePath()
+    {
+        return keyStorePath;
+    }
+
+    public void setKeyStorePath(String keyStorePath)
+    {
+        this.keyStorePath = keyStorePath;
+    }
+
+    public String getKeyStorePassword()
+    {
+        return keyStorePassword;
+    }
+
+    public void setKeyStorePassword(String keyStorePassword)
+    {
+        this.keyStorePassword = keyStorePassword;
+    }
+
+    public String getTrustStorePath()
+    {
+        return trustStorePath;
+    }
+
+    public void setTrustStorePath(String trustStorePath)
+    {
+        this.trustStorePath = trustStorePath;
+    }
+
+    public String getTrustStorePassword()
+    {
+        return trustStorePassword;
+    }
+
+    public void setTrustStorePassword(String trustStorePassword)
+    {
+        this.trustStorePassword = trustStorePassword;
+    }
+
+    public String getCertAlias()
+    {
+        return certAlias;
+    }
+
+    public void setCertAlias(String certAlias)
+    {
+        this.certAlias = certAlias;
+    }
+
+    public boolean isVerifyHostname()
+    {
+        return verifyHostname;
+    }
+
+    public void setVerifyHostname(boolean verifyHostname)
+    {
+        this.verifyHostname = verifyHostname;
+    }
+    
+    public String getKeyStoreCertType()
+    {
+        return keyStoreCertType;
+    }
+
+    public void setKeyStoreCertType(String keyStoreCertType)
+    {
+        this.keyStoreCertType = keyStoreCertType;
+    }
+
+    public String getTrustStoreCertType()
+    {
+        return trustStoreCertType;
+    }
+
+    public void setTrustStoreCertType(String trustStoreCertType)
+    {
+        this.trustStoreCertType = trustStoreCertType;
+    }
+
+    public int getReadBufferSize()
+    {
+        return readBufferSize;
+    }
+
+    public void setReadBufferSize(int readBufferSize)
+    {
+        this.readBufferSize = readBufferSize;
+    }
+
+    public int getWriteBufferSize()
+    {
+        return writeBufferSize;
+    }
+
+    public void setWriteBufferSize(int writeBufferSize)
+    {
+        this.writeBufferSize = writeBufferSize;
+    }
+    
+    public long getTransportTimeout()
+    {
+        return transportTimeout;
+    }
+
+    public void setTransportTimeout(long transportTimeout)
+    {
+        this.transportTimeout = transportTimeout;
+    }
+
+}