[Ubermq-commits] jms/src/com/ubermq/jms/server/ssl SSLProtocol.java,1.7,1.8 IONormalizer.java,1.6,NO
Brought to you by:
jimmyp
From: <ji...@us...> - 2004-01-21 02:05:31
|
Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/server/ssl In directory sc8-pr-cvs1:/tmp/cvs-serv28341/src/com/ubermq/jms/server/ssl Modified Files: SSLProtocol.java Removed Files: IONormalizer.java Log Message: bug fixes related to read/write initialization race conditions Index: SSLProtocol.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/ssl/SSLProtocol.java,v retrieving revision 1.7 retrieving revision 1.8 diff -C2 -d -r1.7 -r1.8 *** SSLProtocol.java 12 Jan 2004 19:24:26 -0000 1.7 --- SSLProtocol.java 21 Jan 2004 02:05:27 -0000 1.8 *************** *** 1,4 **** --- 1,6 ---- package com.ubermq.jms.server.ssl; import com.ubermq.jms.client.unicast.*; + import com.ubermq.jms.common.*; + import com.ubermq.jms.common.ssl.*; import com.ubermq.jms.server.*; import com.ubermq.kernel.*; *************** *** 16,23 **** implements MessageServer.Protocol { - public static final int DEFAULT_PORT = 3994; public static int getProtocolPort() { ! return Integer.valueOf(Configurator.getProperty(ServerConfig.SSL_PORT, String.valueOf(DEFAULT_PORT))).intValue(); } --- 18,24 ---- implements MessageServer.Protocol { public static int getProtocolPort() { ! return Integer.valueOf(Configurator.getProperty(ServerConfig.SSL_PORT, String.valueOf(MessageConstants.DEFAULT_SSL_PORT))).intValue(); } *************** *** 114,118 **** } catch (IOException e) { ! com.ubermq.Utility.getLogger().error("", e); return; } --- 115,119 ---- } catch (IOException e) { ! com.ubermq.util.Utility.getLogger().error("", e); return; } *************** *** 127,131 **** public String toString() { ! return (port == DEFAULT_PORT) ? "Secure UberMQ" : ("Secure UberMQ (" + port + ")"); } --- 128,132 ---- public String toString() { ! return (port == MessageConstants.DEFAULT_SSL_PORT) ? "Secure UberMQ" : ("Secure UberMQ (" + port + ")"); } *************** *** 141,145 **** try { ! if (port == DEFAULT_PORT) return URI.create("ubermqs://" + InetAddress.getLocalHost()); else --- 142,146 ---- try { ! if (port == MessageConstants.DEFAULT_SSL_PORT) return URI.create("ubermqs://" + InetAddress.getLocalHost()); else --- IONormalizer.java DELETED --- |