[jboss-remoting-commits] JBoss Remoting SVN: r3542 - remoting2/branches/2.x/src/main/org/jboss/remoting/transport/sslsocket.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2008-02-29 03:24:59 -0500 (Fri, 29 Feb 2008)
New Revision: 3542

Modified:
   remoting2/branches/2.x/src/main/org/jboss/remoting/transport/sslsocket/SSLSocketClientInvoker.java
Log:
JBREM-703: Added configuration for remaining ssl socket parameters.

Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transport/sslsocket/SSLSocketClientInvoker.java
===================================================================
--- remoting2/branches/2.x/src/main/org/jboss/remoting/transport/sslsocket/SSLSocketClientInvoker.java	2008-02-29 08:24:27 UTC (rev 3541)
+++ remoting2/branches/2.x/src/main/org/jboss/remoting/transport/sslsocket/SSLSocketClientInvoker.java	2008-02-29 08:24:59 UTC (rev 3542)
@@ -36,6 +36,7 @@
 import java.io.IOException;
 import java.net.Socket;
 import java.net.InetSocketAddress;
+import java.net.SocketException;
 import java.util.Map;
 
 /**
@@ -45,6 +46,10 @@
 {
    private static final Logger log = Logger.getLogger(SSLSocketClientInvoker.class);
    private static final boolean isTraceEnabled = log.isTraceEnabled();
+   
+   protected String[] enabledCipherSuites;
+   protected String[] enabledProtocols;
+   protected boolean enableSessionCreation = true;
 
    public SSLSocketClientInvoker(InvokerLocator locator) throws IOException
    {
@@ -74,6 +79,54 @@
       }
    }
 
+   public void setOOBInline(boolean inline)
+   {
+      log.warn("Ignored: sending urgent data is not supported by SSLSockets");
+   }
+   
+   public String[] getEnabledCipherSuites()
+   {
+      return enabledCipherSuites;
+   }
+
+   public void setEnabledCipherSuites(String[] enabledCipherSuites)
+   {
+      this.enabledCipherSuites = enabledCipherSuites;
+   }
+
+   public String[] getEnabledProtocols()
+   {
+      return enabledProtocols;
+   }
+
+   public void setEnabledProtocols(String[] enabledProtocols)
+   {
+      this.enabledProtocols = enabledProtocols;
+   }
+
+   public boolean isEnableSessionCreation()
+   {
+      return enableSessionCreation;
+   }
+
+   public void setEnableSessionCreation(boolean enableSessionCreation)
+   {
+      this.enableSessionCreation = enableSessionCreation;
+   }
+   
+   protected void setup() throws Exception
+   {
+      super.setup();
+      
+      Object o = configuration.get("enabledCipherSuites");
+      if (o instanceof String[])
+         setEnabledCipherSuites((String[]) o);
+      
+      o = configuration.get("enabledProtocols");
+      if (o instanceof String[])
+         setEnabledProtocols((String[]) o);
+   }
+   
    protected SocketFactory createSocketFactory(Map configuration)
    {
       SocketFactory sf = super.createSocketFactory(configuration);
@@ -115,7 +168,7 @@
 
       Socket s = sf.createSocket();
 
-      s.setReuseAddress(getReuseAddress());
+      configureSocket(s);
       InetSocketAddress inetAddr = new InetSocketAddress(address, port);
       
       if (timeout < 0)
@@ -141,6 +194,32 @@
 
       return s;
    }
+   
+   protected void configureSocket(Socket s) throws SocketException
+   {
+      s.setReuseAddress(getReuseAddress());
+      
+      if (keepAliveSet)           s.setKeepAlive(keepAlive);
+      if (receiveBufferSize > -1) s.setReceiveBufferSize(receiveBufferSize);
+      if (sendBufferSize > -1)    s.setSendBufferSize(sendBufferSize);
+      if (soLingerSet && 
+            soLingerDuration > 0) s.setSoLinger(soLinger, soLingerDuration);
+      if (trafficClass > -1)      s.setTrafficClass(trafficClass);
+      
+      if (s instanceof SSLSocket)
+      {
+         SSLSocket ss = (SSLSocket) s;
+         if (enabledCipherSuites != null)
+         {
+            ss.setEnabledCipherSuites(enabledCipherSuites);
+         }
+         if (enabledProtocols != null)
+         {
+            ss.setEnabledProtocols(enabledProtocols);
+         }
+         ss.setEnableSessionCreation(enableSessionCreation);
+      }
+   }
 
    private void establishHandshake(SSLSocket sslSocket, HandshakeCompletedListener listener)
          throws IOException