 |
Return to article
public void run() {
Socket clientSocket = null;
while (true) {
//get out when not bound to server socket
if (serverSocket == null) return;
try {
//listen to sever port. Create socket to client
clientSocket = serverSocket.accept();
//create an instance of the Queue Manager to process request from client
QueueManager qm = new QueueManager(queueContainer, clientSocket, loggingSw);
qm.start();
} catch (IOException e) {
System.out.println("MessageServer:run:1:client socket error");
System.exit(1);
}
}
}
}
|
Return to article
|  |
|