package sjc;
import java.io.*;
import javax.net.ssl.*;
import java.net.*;
import javax.net.*;
public class ListenThread extends Thread {
	public ListenThread(ManagerThread mt) {
		mthread = mt;
	}
	private ManagerThread mthread = null;

	private ObjectQueue queue = new ObjectQueue();
	public ObjectQueue getQueue() {
		return queue;
	}
	public void run() {
		while (!isInterrupted()) {
			proceed(queue.get());
		}
	}
	private void proceed(Object obj) {
		try {
			SSLServerSocket sslserver = (SSLServerSocket) SSLServerSocketFactory.getDefault().createServerSocket(40000);
			sslserver.setEnabledCipherSuites(new String[] {"SSL_DH_anon_WITH_3DES_EDE_CBC_SHA"/* "SSL_DH_anon_WITH_RC4_128_MD5" */ });
			System.out.println("Listening");
			SSLSocket sslclient =(SSLSocket)  sslserver.accept();
			System.out.println("Connection successful");
			mthread.getQueue().put(sslclient);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}