Show ServerThreadWorker.java syntax highlighted
package persister.network;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import persister.Message;
public class ServerThreadWorker extends Thread{
private ServerContext context;
private Socket socket;
private ObjectInputStream in;
private ObjectOutputStream out;
private CallbackThread callback;
public ServerThreadWorker(ServerContext context, Socket socket)throws Exception{
this.context = context;
this.socket = socket;
out = new ObjectOutputStream(socket.getOutputStream());
out.flush();
in = new ObjectInputStream(socket.getInputStream());
//start the thread.
this.start();
}
public void run(){
if(context.getCommunicator() == null){
this.stop();
return;
}
callback = new CallbackThread(in,context.getCommunicator());
}
public void sendMessage(Message msg) throws Exception{
out.writeObject(msg);
}
}
See more files for this project here