Commit 622f4bcd authored by Derek DeMoro's avatar Derek DeMoro Committed by derek

The SocketAcceptThread should accept assigned active port if not using ssl.


git-svn-id: http://svn.igniterealtime.org/svn/repos/messenger/trunk@93 b35dd754-fafc-0310-a699-88a17e54d16e
parent 6edf41f8
......@@ -67,21 +67,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
}
// Now start up the acceptor (and associated read selector)
if ("true".equals(JiveGlobals.getProperty("xmpp.socket.plain.active"))) {
socketThread = new SocketAcceptThread(this);
ports.add(new ServerPortImpl(socketThread.getPort(),
serverName,
localIPAddress,
false,
null));
socketThread.setDaemon(true);
socketThread.start();
List params = new ArrayList();
params.add(Integer.toString(socketThread.getPort()));
Log.info(LocaleUtils.getLocalizedString("startup.plain", params));
}
if ("true".equals(JiveGlobals.getProperty("xmpp.socket.ssl.active"))) {
if ("true".equals(JiveGlobals.getProperty("xmpp.socket.ssl.active"))) {
try {
sslSocketThread = new SSLSocketAcceptThread(this);
String algorithm =
......@@ -105,6 +91,21 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
Log.error(LocaleUtils.getLocalizedString("admin.error.ssl"), e);
}
}
else {
socketThread = new SocketAcceptThread(this);
ports.add(new ServerPortImpl(socketThread.getPort(),
serverName,
localIPAddress,
false,
null));
socketThread.setDaemon(true);
socketThread.start();
List params = new ArrayList();
params.add(Integer.toString(socketThread.getPort()));
Log.info(LocaleUtils.getLocalizedString("startup.plain", params));
}
}
public Iterator getPorts() {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment