/**
 * 
 */
package de.test;

import java.util.Properties;

import javax.naming.Context;
import javax.naming.InitialContext;

/**
 * @author sjankus
 *
 */
public class TestClient {
	
	/** The JNDI-Name */
	private static final String JNDI_NAME = "ejb:TestServer/TestEJB/TestServerBean!de.test.TestServer";
	
	/** Amount of Threads to be started */
	private static final int NUMMER_OFF_THREADS = 1000;
	
	/** Time to wait befor starting the next thread */
	private static long TIME_TO_WAIT = 10;
	
	private static Properties CONTEXT_PROPERTIES = new Properties();
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		try {
			new TestClient().doExecute();
		} catch (Exception e) {
			e.printStackTrace();
			System.exit(-1);
		}
	}
	
	private void doExecute() throws Exception {
		CONTEXT_PROPERTIES.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");
		
		for (int x=0; x<NUMMER_OFF_THREADS; x++) {
			TestRun t = new TestRun("Thread-"+x);
			t.start();
			Thread.sleep(TIME_TO_WAIT);
		}
	}
	
	private class TestRun extends Thread {
		
		private String name;
		
		/**
		 * Constructor
		 * @param name
		 */
		public TestRun(String name) {
			this.name=name;
		}

		/* (non-Javadoc)
		 * @see java.lang.Runnable#run()
		 */
		@Override
		public void run() {
			try {
				InitialContext jndiContext = new InitialContext(CONTEXT_PROPERTIES);
				TestServer server = (TestServer) jndiContext.lookup(JNDI_NAME);
				server.doTest(name);
			} catch (Exception e) {
				System.out.println("ERROR "+name);
				e.printStackTrace();
			}
		}
	}
}