Commit 71cfe1e4 authored by Matt Tucker's avatar Matt Tucker Committed by matt

Minor fixes.


git-svn-id: http://svn.igniterealtime.org/svn/repos/messenger/trunk@112 b35dd754-fafc-0310-a699-88a17e54d16e
parent 4a00801b
...@@ -29,7 +29,7 @@ import java.net.UnknownHostException; ...@@ -29,7 +29,7 @@ import java.net.UnknownHostException;
public class SocketAcceptThread extends Thread { public class SocketAcceptThread extends Thread {
/** /**
* The default Jabber socket. * The default XMPP port.
*/ */
public static final int DEFAULT_PORT = 5222; public static final int DEFAULT_PORT = 5222;
...@@ -58,11 +58,7 @@ public class SocketAcceptThread extends Thread { ...@@ -58,11 +58,7 @@ public class SocketAcceptThread extends Thread {
public SocketAcceptThread(ConnectionManager connManager) { public SocketAcceptThread(ConnectionManager connManager) {
super("SAT accept"); super("SAT accept");
this.connManager = connManager; this.connManager = connManager;
port = SocketAcceptThread.DEFAULT_PORT; port = JiveGlobals.getIntProperty("xmpp.socket.plain.port", DEFAULT_PORT);
String portName = JiveGlobals.getProperty("xmpp.socket.plain.port");
if (portName != null) {
port = Integer.parseInt(portName);
}
String interfaceName = JiveGlobals.getProperty("xmpp.socket.plain.interface"); String interfaceName = JiveGlobals.getProperty("xmpp.socket.plain.interface");
bindInterface = null; bindInterface = null;
if (interfaceName != null) { if (interfaceName != null) {
......
...@@ -94,10 +94,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana ...@@ -94,10 +94,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
else { else {
socketThread = new SocketAcceptThread(this); socketThread = new SocketAcceptThread(this);
ports.add(new ServerPortImpl(socketThread.getPort(), ports.add(new ServerPortImpl(socketThread.getPort(),
serverName, serverName, localIPAddress, false, null));
localIPAddress,
false,
null));
socketThread.setDaemon(true); socketThread.setDaemon(true);
socketThread.start(); socketThread.start();
...@@ -105,7 +102,6 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana ...@@ -105,7 +102,6 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
params.add(Integer.toString(socketThread.getPort())); params.add(Integer.toString(socketThread.getPort()));
Log.info(LocaleUtils.getLocalizedString("startup.plain", params)); Log.info(LocaleUtils.getLocalizedString("startup.plain", params));
} }
} }
public Iterator getPorts() { public Iterator getPorts() {
...@@ -129,11 +125,8 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana ...@@ -129,11 +125,8 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
isSecure); isSecure);
Session session = sessionManager.createSession(conn); Session session = sessionManager.createSession(conn);
SocketReadThread reader = new SocketReadThread(router, SocketReadThread reader = new SocketReadThread(router,
packetFactory, packetFactory, serverName, auditManager.getAuditor(),
serverName, sock, session);
auditManager.getAuditor(),
sock,
session);
reader.setDaemon(true); reader.setDaemon(true);
reader.start(); reader.start();
} }
......
...@@ -86,7 +86,7 @@ public class AcceptManagerImpl extends BasicModule implements AcceptManager { ...@@ -86,7 +86,7 @@ public class AcceptManagerImpl extends BasicModule implements AcceptManager {
throw new AlreadyExistsException(portAddress.toString()); throw new AlreadyExistsException(portAddress.toString());
} }
} }
AcceptPort acceptPort = new AcceptPortImpl("port" + ports.size(), AcceptPort acceptPort = new AcceptPortImpl("acceptPorts.port" + ports.size(),
connManager, portAddress); connManager, portAddress);
ports.add(acceptPort); ports.add(acceptPort);
return acceptPort; return acceptPort;
...@@ -125,6 +125,12 @@ public class AcceptManagerImpl extends BasicModule implements AcceptManager { ...@@ -125,6 +125,12 @@ public class AcceptManagerImpl extends BasicModule implements AcceptManager {
AcceptPort port = new AcceptPortImpl(propName, connManager); AcceptPort port = new AcceptPortImpl(propName, connManager);
ports.add(port); ports.add(port);
} }
if (ports.size() == 0) {
// Add a default
JiveGlobals.setProperty("acceptPorts.port1.portnumber", "5222");
AcceptPort port = new AcceptPortImpl("acceptPorts.port1", connManager);
ports.add(port);
}
} }
} }
} }
...@@ -38,8 +38,17 @@ public class AcceptPortImpl implements AcceptPort { ...@@ -38,8 +38,17 @@ public class AcceptPortImpl implements AcceptPort {
this.context = context; this.context = context;
conManager = connectionManager; conManager = connectionManager;
String hostname = JiveGlobals.getProperty(context + ".hostname"); String hostname = JiveGlobals.getProperty(context + ".hostname");
String port = JiveGlobals.getProperty(".portnumber"); int port = JiveGlobals.getIntProperty(context + ".portnumber", -1);
address = new InetSocketAddress(hostname,Integer.parseInt(port)); if (port == -1) {
Log.error("No port number set for " + context);
return;
}
if (hostname == null) {
address = new InetSocketAddress(port);
}
else {
address = new InetSocketAddress(hostname, port);
}
} }
public AcceptPortImpl(String context, ConnectionManager connectionManager, public AcceptPortImpl(String context, ConnectionManager connectionManager,
......
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