/**
 * 
 */
package de.test;

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

/**
 * @author sjankus
 *
 */
public class TestClient {
	
	/** The JNDI-Name */
	private static final String JNDI_NAME = "TestServer/TestEJB/TestServerBean!de.test.TestServer";
	
	/** Amount of Threads to be started */
	private static final int NUMMER_OFF_THREADS = 500;
	
	/** Time to wait befor starting the next thread */
	private static long TIME_TO_WAIT = 100;
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		try {
			TestClient tc = new TestClient();
			tc.setSystemProperties();
			tc.doExecute();
		} catch (Exception e) {
			e.printStackTrace();
			System.exit(-1);
		}
	}
	
	private void doExecute() throws InterruptedException {
		for (int x=0; x<NUMMER_OFF_THREADS; x++) {
			TestRun t = new TestRun("Thread-"+x);
			t.start();
			Thread.sleep(TIME_TO_WAIT);
		}
	}
	
	/**
	 * Setzt die SystemProperties (naming.factory, naming.provider, usw.).
	 */
	public void setSystemProperties() throws Exception {	
		
		// java.naming.factory.initial
		System.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.jboss.naming.remote.client.InitialContextFactory");
		
		// java.naming.provider.url
		System.setProperty(Context.PROVIDER_URL, "remote://localhost:4447");
		
		// username - java.naming.security.principal
		System.setProperty(Context.SECURITY_PRINCIPAL, "sf");
		
		// password - java.naming.security.credentials
		System.setProperty(Context.SECURITY_CREDENTIALS, "efREporter@2014");
		
		// This is an important property to set if you want to do EJB invocations via the remote-naming project
		System.setProperty("jboss.naming.client.ejb.context", "true");
		
		System.setProperty("org.jboss.ejb.client.scoped.context", "true");
		
		// Merker, dass die Properties eingelesen wurden.
		System.setProperty("efreporter.config.ready", "true");
	}
	
	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 {
				System.out.println("Start "+name);
				InitialContext jndiContext = new InitialContext(System.getProperties());
				TestServer server = (TestServer) jndiContext.lookup(JNDI_NAME);
				server.doTest(name);
				server = null;
				jndiContext.close();
				System.out.println("Stop "+name);
			} catch (NamingException e) {
				System.out.println("ERROR "+name);
				e.printStackTrace();
			}
		}
		
	}
}