plugins/org.eclipse.osee.ote.server/src/org/eclipse/osee/ote/server/internal/OteServiceStarterImpl.java - osee/org.eclipse.osee - Git at Google

 /*******************************************************************************
  * Copyright (c) 2010 Boeing.
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License v1.0
  * which accompanies this distribution, and is available at
  * http://www.eclipse.org/legal/epl-v10.html
  *
  * Contributors:
  *     Boeing - initial API and implementation
  *******************************************************************************/
 package org.eclipse.osee.ote.server.internal;

 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.io.ObjectOutputStream;
 import java.io.Serializable;
 import java.net.Inet6Address;
 import java.net.InetAddress;
 import java.net.URI;
 import java.net.UnknownHostException;
 import java.rmi.RemoteException;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import java.util.logging.Level;

 import org.apache.activemq.broker.BrokerService;
 import org.eclipse.osee.connection.service.IConnectionService;
 import org.eclipse.osee.connection.service.IServiceConnector;
 import org.eclipse.osee.framework.jdk.core.type.OseeCoreException;
 import org.eclipse.osee.framework.jdk.core.type.OseeStateException;
 import org.eclipse.osee.framework.jdk.core.util.network.PortUtil;
 import org.eclipse.osee.framework.logging.OseeLog;
 import org.eclipse.osee.framework.messaging.MessageService;
 import org.eclipse.osee.framework.messaging.NodeInfo;
 import org.eclipse.osee.framework.messaging.OseeMessagingListener;
 import org.eclipse.osee.framework.messaging.OseeMessagingStatusCallback;
 import org.eclipse.osee.framework.messaging.ReplyConnection;
 import org.eclipse.osee.framework.messaging.services.ServiceInfoPopulator;
 import org.eclipse.osee.framework.messaging.services.messages.ServiceDescriptionPair;
 import org.eclipse.osee.framework.plugin.core.util.ExportClassLoader;
 import org.eclipse.osee.ote.core.OTESessionManager;
 import org.eclipse.osee.ote.core.OteBaseMessages;
 import org.eclipse.osee.ote.core.environment.interfaces.IHostTestEnvironment;
 import org.eclipse.osee.ote.core.environment.interfaces.IRuntimeLibraryManager;
 import org.eclipse.osee.ote.core.environment.interfaces.ITestEnvironmentServiceConfig;
 import org.eclipse.osee.ote.master.rest.client.OTEMasterServer;
 import org.eclipse.osee.ote.master.rest.client.OTEMasterServerResult;
 import org.eclipse.osee.ote.master.rest.model.OTEServer;
 import org.eclipse.osee.ote.server.OteServiceStarter;
 import org.eclipse.osee.ote.server.PropertyParamter;
 import org.eclipse.osee.ote.server.TestEnvironmentFactory;
 import org.osgi.framework.FrameworkUtil;
 import org.osgi.service.packageadmin.PackageAdmin;

 /**
  * @author Andrew M. Finkbeiner
  */
 public class OteServiceStarterImpl implements OteServiceStarter, ServiceInfoPopulator, OseeMessagingStatusCallback {

 	private PackageAdmin packageAdmin;
 	private IRuntimeLibraryManager runtimeLibraryManager;
 	private IConnectionService connectionService;
 	private MessageService messageService;

 	private BrokerService brokerService;
 	private OteService service;
 	private final ListenForHostRequest listenForHostRequest;

 	private IServiceConnector serviceSideConnector;
    private OTESessionManager oteSessions;
    private OTEMasterServer masterServer;

    private ScheduledExecutorService executor;
    private OTEServer oteServerEntry;
    private ScheduledFuture<?> taskToCancel;
    private LookupRegistration lookupRegistration;
    private URI masterURI;
    private NodeInfo nodeInfo;
    private int brokerPort = 0;

    public OteServiceStarterImpl() {
       listenForHostRequest = new ListenForHostRequest();
       executor = Executors.newSingleThreadScheduledExecutor(new ThreadFactory(){

          @Override
          public Thread newThread(Runnable arg0) {
             Thread th = new Thread(arg0);
             th.setName("OTE Lookup Registration");
             th.setDaemon(true);
             return th;
          }

       });
    }

    public void bindOTESessionManager(OTESessionManager oteSessions){
       this.oteSessions = oteSessions;
    }

    public void unbindOTESessionManager(OTESessionManager oteSessions){
       this.oteSessions = null;
    }

 	public void bindIRuntimeLibraryManager(IRuntimeLibraryManager runtimeLibraryManager){
 	   this.runtimeLibraryManager = runtimeLibraryManager;
 	}

 	public void unbindIRuntimeLibraryManager(IRuntimeLibraryManager runtimeLibraryManager){
       this.runtimeLibraryManager = null;
    }

 	public void bindMessageService(MessageService messageService){
 	   this.messageService = messageService;
 	}

 	public void unbindMessageService(MessageService messageService){
 	   this.messageService = null;
 	}

 	public void bindIConnectionService(IConnectionService connectionService){
 	   this.connectionService = connectionService;
 	}

 	public void unbindIConnectionService(IConnectionService connectionService){
 	   this.connectionService = null;
 	}

 	public void bindOTEMasterServer(OTEMasterServer masterServer){
 	   this.masterServer = masterServer;
 	}

 	public void unbindOTEMasterServer(OTEMasterServer masterServer){
       this.masterServer = null;
    }

 	public void bindPackageAdmin(PackageAdmin packageAdmin){
 	   this.packageAdmin = packageAdmin;
 	}

 	public void unbindPackageAdmin(PackageAdmin packageAdmin){
       this.packageAdmin = null;
    }

 	@Override
 	public IHostTestEnvironment start(IServiceConnector serviceSideConnector, ITestEnvironmentServiceConfig config, PropertyParamter propertyParameter, String environmentFactoryClass) throws Exception {
 		return start(serviceSideConnector, config, propertyParameter, null, environmentFactoryClass);
 	}

 	@Override
 	public IHostTestEnvironment start(IServiceConnector serviceSideConnector, ITestEnvironmentServiceConfig config, PropertyParamter propertyParameter, TestEnvironmentFactory factory) throws Exception {
 		return start(serviceSideConnector, config, propertyParameter, factory, null);
 	}

 	private IHostTestEnvironment start(IServiceConnector serviceSideConnector, ITestEnvironmentServiceConfig config, PropertyParamter propertyParameter, TestEnvironmentFactory factory, String environmentFactoryClass) throws Exception {
 		if (service != null) {
 			throw new OseeStateException("An ote Server has already been started.");
 		}
 		this.serviceSideConnector = serviceSideConnector;
 		if(System.getProperty("org.osgi.service.http.port") == null){
 		   System.out.println("Property org.osgi.service.http.port was not set, it will default to port 80.");
 		} else {
 		   System.out.printf("BETA SERVER URL[http://%s:%s/ote]\n", InetAddress.getLocalHost().getHostAddress(), Integer.parseInt(System.getProperty("org.osgi.service.http.port")));
 		}
 		brokerService = new BrokerService();

 		String strUri;
 		try {
 			String addressAsString = getAddress();
 			if(brokerPort <= 0){
 			   brokerPort = getServerPort();
 			}
 			strUri = String.format("tcp://%s:%d", addressAsString, brokerPort);
 			try {
 				brokerService.addConnector(strUri);
 				OseeLog.log(getClass(), Level.INFO, "Added TCP connector: " + strUri);
 			} catch (Exception e) {
 				OseeLog.log(getClass(), Level.SEVERE, "could not add connector for " + strUri, e);
 				strUri = "vm://localhost?broker.persistent=false";
 			}
 		} catch (Exception e) {
 			OseeLog.log(getClass(), Level.SEVERE, "could acquire a TCP address", e);
 			strUri = "vm://localhost?broker.persistent=false";
 		}
 		//necessary for rmi/jini classloading
 		Thread.currentThread().setContextClassLoader(ExportClassLoader.getInstance());

 		brokerService.setEnableStatistics(false);
 		brokerService.setBrokerName("OTEServer");
 		brokerService.setPersistent(false);
 		brokerService.setUseJmx(false);
 		brokerService.start();
 		URI uri = new URI(strUri);

 		System.out.printf("SERVER CONNECTION(ACTIVEMQ) URI[\n\t%s\n]\n", strUri);

 		nodeInfo = new NodeInfo("OTEEmbeddedBroker", uri);

 		EnvironmentCreationParameter environmentCreationParameter =
 				new EnvironmentCreationParameter(runtimeLibraryManager, nodeInfo, serviceSideConnector, config, factory,
 						environmentFactoryClass);

 		service =
 				new OteService(runtimeLibraryManager, environmentCreationParameter, oteSessions, propertyParameter,
 						serviceSideConnector.getProperties());

 		serviceSideConnector.init(service);


 		if (propertyParameter.isLocalConnector() || propertyParameter.useJiniLookup()) {
 			connectionService.addConnector(serviceSideConnector);
 		}
 		if (!propertyParameter.isLocalConnector()) {
 			String masterURIStr = System.getProperty("ote.master.uri");
 			if(masterURIStr != null){
 			   try{
 			      messageService.get(nodeInfo).subscribe(OteBaseMessages.RequestOteHost, listenForHostRequest, this);
 			      masterURI = new URI(masterURIStr);
 			      oteServerEntry = createOTEServer(nodeInfo, environmentCreationParameter, propertyParameter, service.getServiceID().toString());
 			      lookupRegistration = new LookupRegistration(masterURI, masterServer, oteServerEntry, service);
 			      taskToCancel = executor.scheduleAtFixedRate(lookupRegistration, 0, 30, TimeUnit.SECONDS);
 			   } catch(Throwable th){
 			      OseeLog.log(getClass(), Level.SEVERE, th);
 			   }
 			} else { //user old lookup
 				OseeLog.log(getClass(), Level.SEVERE, "'ote.master.uri' was not set.  You must use direct connect from the client.");
 			}

 		} else {
 			serviceSideConnector.setProperty("OTEEmbeddedBroker", nodeInfo);
 		}

 		FrameworkUtil.getBundle(getClass()).getBundleContext().registerService(IHostTestEnvironment.class, service, null);

 		return service;
 	}

 	private OTEServer createOTEServer(NodeInfo nodeInfo, EnvironmentCreationParameter environmentCreationParameter, PropertyParamter propertyParameter, String uuid) throws NumberFormatException, UnknownHostException{
 	   OTEServer server = new OTEServer();
 	   server.setName(environmentCreationParameter.getServerTitle().toString());
 	   server.setStation(propertyParameter.getStation());
 	   server.setVersion(propertyParameter.getVersion());
 	   server.setType(propertyParameter.getType());
 	   server.setComment(propertyParameter.getComment());
 	   server.setStartTime(new Date().toString());
 	   server.setOwner(System.getProperty("user.name"));
 	   server.setUUID(uuid);
 	   if(System.getProperty("org.osgi.service.http.port") == null){
 	      server.setOteRestServer(String.format("http://%s:%s", InetAddress.getLocalHost().getHostAddress(), 80));
 	   } else {
 	      server.setOteRestServer(String.format("http://%s:%s", InetAddress.getLocalHost().getHostAddress(), Integer.parseInt(System.getProperty("org.osgi.service.http.port"))));
 	   }
 	   server.setOteActivemqServer(nodeInfo.getUri().toString());
 	   return server;
 	}

 	private int getServerPort() throws IOException {
 		String portFromLaunch = System.getProperty("ote.server.broker.uri.port");
 		int port = 0;
 		if (portFromLaunch != null) {
 			try {
 				port = Integer.parseInt(portFromLaunch);
 			} catch (NumberFormatException ex) {
 			}
 		}
 		if (port == 0) {
 			port = PortUtil.getInstance().getValidPort();
 		}
 		return port;
 	}

 	@Override
 	public void stop() {
 	   if(messageService != null && nodeInfo != null){
 	      try {
             messageService.get(nodeInfo).send(OteBaseMessages.OteHostShutdown, service.getServiceID().toString());
          } catch (OseeCoreException e) {
             OseeLog.log(getClass(), Level.SEVERE, e);
          } catch (RemoteException e) {
             OseeLog.log(getClass(), Level.SEVERE, e);
          }
 	   }
 		if (service != null) {
 			try {
 				service.updateDynamicInfo();
 				service.kill();
 				service = null;
 			} catch (Exception ex) {
 				OseeLog.log(getClass(), Level.SEVERE, ex);
 			}
 		}
 		if (brokerService != null) {
 			try {
 				brokerService.stopGracefully(".*", ".*", 10000, 500);
 				brokerService.stop();
 			} catch (Exception ex) {
 				OseeLog.log(getClass(), Level.SEVERE, ex);
 			}
 		}
 		if (serviceSideConnector != null) {
 			try {
 				connectionService.removeConnector(serviceSideConnector);
 			} catch (Exception ex) {
 				OseeLog.log(getClass(), Level.SEVERE, ex);
 			}
 		}
 		if(oteServerEntry != null) {
 		   try{
 		      lookupRegistration.stop();
 		      taskToCancel.cancel(true);
 		   } finally {
 		      Future<OTEMasterServerResult> removeServer = masterServer.removeServer(masterURI, oteServerEntry);
 		      try {
                removeServer.get(1000, TimeUnit.MILLISECONDS);
             } catch (InterruptedException e) {
             } catch (ExecutionException e) {
             } catch (TimeoutException e) {
             }
 		   }
 		}
 		brokerService = null;
 	}

 	private String getAddress() throws UnknownHostException {
 		InetAddress[] all = InetAddress.getAllByName(InetAddress.getLocalHost().getHostName());
 		String defaultAddress = all[0].getHostAddress();
 		for (InetAddress address : all ) {
 		   if(!address.isSiteLocalAddress())
 		   {
 		      String firstRealLocalAddress = address.getHostAddress();
 		      if (address instanceof Inet6Address) {
 		         firstRealLocalAddress = "[" + firstRealLocalAddress + "]";
 		      }
 		      return firstRealLocalAddress;
 		   }
 		}
 		return defaultAddress;
 	}

 	private class ListenForHostRequest extends OseeMessagingListener {

 		@Override
 		public void process(Object message, Map<String, Object> headers, ReplyConnection replyConnection) {
 			if (replyConnection.isReplyRequested()) {
 				try {
 					ByteArrayOutputStream baos = new ByteArrayOutputStream();
 					ObjectOutputStream oos = new ObjectOutputStream(baos);
 					oos.writeObject(message);
 					oos.writeObject(serviceSideConnector.getService());
 					replyConnection.send(baos.toByteArray(), null, OteServiceStarterImpl.this);
 				} catch (OseeCoreException ex) {
 					OseeLog.log(getClass(), Level.SEVERE, ex);
 				} catch (IOException ex) {
 					OseeLog.log(getClass(), Level.SEVERE, ex);
 				}
 			}
 		}
 	}

 	@Override
 	public void updateServiceInfo(List<ServiceDescriptionPair> serviceDescription) {
 		for (Entry<String, Serializable> entry : serviceSideConnector.getProperties().entrySet()) {
 			ServiceDescriptionPair pair = new ServiceDescriptionPair();
 			if (entry.getKey() != null && entry.getValue() != null) {
 				pair.setName(entry.getKey());
 				pair.setValue(entry.getValue().toString());
 				serviceDescription.add(pair);
 			}
 		}
 	}

 	@Override
 	public void fail(Throwable th) {
 		OseeLog.log(getClass(), Level.SEVERE, th);
 	}

 	@Override
 	public void success() {
 	}

 	private static class LookupRegistration implements Runnable {

       private final OTEMasterServer masterServer;
       private final OTEServer server;
       private final URI uri;
       private volatile boolean run = true;
       private final OteService service;

       public LookupRegistration(URI uri, OTEMasterServer masterServer, OTEServer server, OteService service) {
          this.masterServer = masterServer;
          this.server = server;
          this.uri = uri;
          this.service = service;
       }

       @Override
       public void run() {
          try{
             if(run){
                server.setConnectedUsers(service.getProperties().getProperty("user_list", "N.A.").toString());
                masterServer.addServer(uri, server);
             }
          } catch (Throwable th){
             th.printStackTrace();
          }
       }

       public void stop(){
          run = false;
       }

 	}

 }
	/*******************************************************************************
	* Copyright (c) 2010 Boeing.
	* All rights reserved. This program and the accompanying materials
	* are made available under the terms of the Eclipse Public License v1.0
	* which accompanies this distribution, and is available at
	* http://www.eclipse.org/legal/epl-v10.html
	*
	* Contributors:
	* Boeing - initial API and implementation
	*******************************************************************************/
	package org.eclipse.osee.ote.server.internal;

	import java.io.ByteArrayOutputStream;
	import java.io.IOException;
	import java.io.ObjectOutputStream;
	import java.io.Serializable;
	import java.net.Inet6Address;
	import java.net.InetAddress;
	import java.net.URI;
	import java.net.UnknownHostException;
	import java.rmi.RemoteException;
	import java.util.Date;
	import java.util.List;
	import java.util.Map;
	import java.util.Map.Entry;
	import java.util.concurrent.ExecutionException;
	import java.util.concurrent.Executors;
	import java.util.concurrent.Future;
	import java.util.concurrent.ScheduledExecutorService;
	import java.util.concurrent.ScheduledFuture;
	import java.util.concurrent.ThreadFactory;
	import java.util.concurrent.TimeUnit;
	import java.util.concurrent.TimeoutException;
	import java.util.logging.Level;

	import org.apache.activemq.broker.BrokerService;
	import org.eclipse.osee.connection.service.IConnectionService;
	import org.eclipse.osee.connection.service.IServiceConnector;
	import org.eclipse.osee.framework.jdk.core.type.OseeCoreException;
	import org.eclipse.osee.framework.jdk.core.type.OseeStateException;
	import org.eclipse.osee.framework.jdk.core.util.network.PortUtil;
	import org.eclipse.osee.framework.logging.OseeLog;
	import org.eclipse.osee.framework.messaging.MessageService;
	import org.eclipse.osee.framework.messaging.NodeInfo;
	import org.eclipse.osee.framework.messaging.OseeMessagingListener;
	import org.eclipse.osee.framework.messaging.OseeMessagingStatusCallback;
	import org.eclipse.osee.framework.messaging.ReplyConnection;
	import org.eclipse.osee.framework.messaging.services.ServiceInfoPopulator;
	import org.eclipse.osee.framework.messaging.services.messages.ServiceDescriptionPair;
	import org.eclipse.osee.framework.plugin.core.util.ExportClassLoader;
	import org.eclipse.osee.ote.core.OTESessionManager;
	import org.eclipse.osee.ote.core.OteBaseMessages;
	import org.eclipse.osee.ote.core.environment.interfaces.IHostTestEnvironment;
	import org.eclipse.osee.ote.core.environment.interfaces.IRuntimeLibraryManager;
	import org.eclipse.osee.ote.core.environment.interfaces.ITestEnvironmentServiceConfig;
	import org.eclipse.osee.ote.master.rest.client.OTEMasterServer;
	import org.eclipse.osee.ote.master.rest.client.OTEMasterServerResult;
	import org.eclipse.osee.ote.master.rest.model.OTEServer;
	import org.eclipse.osee.ote.server.OteServiceStarter;
	import org.eclipse.osee.ote.server.PropertyParamter;
	import org.eclipse.osee.ote.server.TestEnvironmentFactory;
	import org.osgi.framework.FrameworkUtil;
	import org.osgi.service.packageadmin.PackageAdmin;

	/**
	* @author Andrew M. Finkbeiner
	*/
	public class OteServiceStarterImpl implements OteServiceStarter, ServiceInfoPopulator, OseeMessagingStatusCallback {

	private PackageAdmin packageAdmin;
	private IRuntimeLibraryManager runtimeLibraryManager;
	private IConnectionService connectionService;
	private MessageService messageService;

	private BrokerService brokerService;
	private OteService service;
	private final ListenForHostRequest listenForHostRequest;

	private IServiceConnector serviceSideConnector;
	private OTESessionManager oteSessions;
	private OTEMasterServer masterServer;

	private ScheduledExecutorService executor;
	private OTEServer oteServerEntry;
	private ScheduledFuture<?> taskToCancel;
	private LookupRegistration lookupRegistration;
	private URI masterURI;
	private NodeInfo nodeInfo;
	private int brokerPort = 0;

	public OteServiceStarterImpl() {
	listenForHostRequest = new ListenForHostRequest();
	executor = Executors.newSingleThreadScheduledExecutor(new ThreadFactory(){

	@Override
	public Thread newThread(Runnable arg0) {
	Thread th = new Thread(arg0);
	th.setName("OTE Lookup Registration");
	th.setDaemon(true);
	return th;
	}

	});
	}

	public void bindOTESessionManager(OTESessionManager oteSessions){
	this.oteSessions = oteSessions;
	}

	public void unbindOTESessionManager(OTESessionManager oteSessions){
	this.oteSessions = null;
	}

	public void bindIRuntimeLibraryManager(IRuntimeLibraryManager runtimeLibraryManager){
	this.runtimeLibraryManager = runtimeLibraryManager;
	}

	public void unbindIRuntimeLibraryManager(IRuntimeLibraryManager runtimeLibraryManager){
	this.runtimeLibraryManager = null;
	}

	public void bindMessageService(MessageService messageService){
	this.messageService = messageService;
	}

	public void unbindMessageService(MessageService messageService){
	this.messageService = null;
	}

	public void bindIConnectionService(IConnectionService connectionService){
	this.connectionService = connectionService;
	}

	public void unbindIConnectionService(IConnectionService connectionService){
	this.connectionService = null;
	}

	public void bindOTEMasterServer(OTEMasterServer masterServer){
	this.masterServer = masterServer;
	}

	public void unbindOTEMasterServer(OTEMasterServer masterServer){
	this.masterServer = null;
	}

	public void bindPackageAdmin(PackageAdmin packageAdmin){
	this.packageAdmin = packageAdmin;
	}

	public void unbindPackageAdmin(PackageAdmin packageAdmin){
	this.packageAdmin = null;
	}

	@Override
	public IHostTestEnvironment start(IServiceConnector serviceSideConnector, ITestEnvironmentServiceConfig config, PropertyParamter propertyParameter, String environmentFactoryClass) throws Exception {
	return start(serviceSideConnector, config, propertyParameter, null, environmentFactoryClass);
	}

	@Override
	public IHostTestEnvironment start(IServiceConnector serviceSideConnector, ITestEnvironmentServiceConfig config, PropertyParamter propertyParameter, TestEnvironmentFactory factory) throws Exception {
	return start(serviceSideConnector, config, propertyParameter, factory, null);
	}

	private IHostTestEnvironment start(IServiceConnector serviceSideConnector, ITestEnvironmentServiceConfig config, PropertyParamter propertyParameter, TestEnvironmentFactory factory, String environmentFactoryClass) throws Exception {
	if (service != null) {
	throw new OseeStateException("An ote Server has already been started.");
	}
	this.serviceSideConnector = serviceSideConnector;
	if(System.getProperty("org.osgi.service.http.port") == null){
	System.out.println("Property org.osgi.service.http.port was not set, it will default to port 80.");
	} else {
	System.out.printf("BETA SERVER URL[http://%s:%s/ote]\n", InetAddress.getLocalHost().getHostAddress(), Integer.parseInt(System.getProperty("org.osgi.service.http.port")));
	}
	brokerService = new BrokerService();

	String strUri;
	try {
	String addressAsString = getAddress();
	if(brokerPort <= 0){
	brokerPort = getServerPort();
	}
	strUri = String.format("tcp://%s:%d", addressAsString, brokerPort);
	try {
	brokerService.addConnector(strUri);
	OseeLog.log(getClass(), Level.INFO, "Added TCP connector: " + strUri);
	} catch (Exception e) {
	OseeLog.log(getClass(), Level.SEVERE, "could not add connector for " + strUri, e);
	strUri = "vm://localhost?broker.persistent=false";
	}
	} catch (Exception e) {
	OseeLog.log(getClass(), Level.SEVERE, "could acquire a TCP address", e);
	strUri = "vm://localhost?broker.persistent=false";
	}
	//necessary for rmi/jini classloading
	Thread.currentThread().setContextClassLoader(ExportClassLoader.getInstance());

	brokerService.setEnableStatistics(false);
	brokerService.setBrokerName("OTEServer");
	brokerService.setPersistent(false);
	brokerService.setUseJmx(false);
	brokerService.start();
	URI uri = new URI(strUri);

	System.out.printf("SERVER CONNECTION(ACTIVEMQ) URI[\n\t%s\n]\n", strUri);

	nodeInfo = new NodeInfo("OTEEmbeddedBroker", uri);

	EnvironmentCreationParameter environmentCreationParameter =
	new EnvironmentCreationParameter(runtimeLibraryManager, nodeInfo, serviceSideConnector, config, factory,
	environmentFactoryClass);

	service =
	new OteService(runtimeLibraryManager, environmentCreationParameter, oteSessions, propertyParameter,
	serviceSideConnector.getProperties());

	serviceSideConnector.init(service);



	if (propertyParameter.isLocalConnector() \|\| propertyParameter.useJiniLookup()) {
	connectionService.addConnector(serviceSideConnector);
	}
	if (!propertyParameter.isLocalConnector()) {
	String masterURIStr = System.getProperty("ote.master.uri");
	if(masterURIStr != null){
	try{
	messageService.get(nodeInfo).subscribe(OteBaseMessages.RequestOteHost, listenForHostRequest, this);
	masterURI = new URI(masterURIStr);
	oteServerEntry = createOTEServer(nodeInfo, environmentCreationParameter, propertyParameter, service.getServiceID().toString());
	lookupRegistration = new LookupRegistration(masterURI, masterServer, oteServerEntry, service);
	taskToCancel = executor.scheduleAtFixedRate(lookupRegistration, 0, 30, TimeUnit.SECONDS);
	} catch(Throwable th){
	OseeLog.log(getClass(), Level.SEVERE, th);
	}
	} else { //user old lookup
	OseeLog.log(getClass(), Level.SEVERE, "'ote.master.uri' was not set. You must use direct connect from the client.");
	}

	} else {
	serviceSideConnector.setProperty("OTEEmbeddedBroker", nodeInfo);
	}

	FrameworkUtil.getBundle(getClass()).getBundleContext().registerService(IHostTestEnvironment.class, service, null);

	return service;
	}

	private OTEServer createOTEServer(NodeInfo nodeInfo, EnvironmentCreationParameter environmentCreationParameter, PropertyParamter propertyParameter, String uuid) throws NumberFormatException, UnknownHostException{
	OTEServer server = new OTEServer();
	server.setName(environmentCreationParameter.getServerTitle().toString());
	server.setStation(propertyParameter.getStation());
	server.setVersion(propertyParameter.getVersion());
	server.setType(propertyParameter.getType());
	server.setComment(propertyParameter.getComment());
	server.setStartTime(new Date().toString());
	server.setOwner(System.getProperty("user.name"));
	server.setUUID(uuid);
	if(System.getProperty("org.osgi.service.http.port") == null){
	server.setOteRestServer(String.format("http://%s:%s", InetAddress.getLocalHost().getHostAddress(), 80));
	} else {
	server.setOteRestServer(String.format("http://%s:%s", InetAddress.getLocalHost().getHostAddress(), Integer.parseInt(System.getProperty("org.osgi.service.http.port"))));
	}
	server.setOteActivemqServer(nodeInfo.getUri().toString());
	return server;
	}

	private int getServerPort() throws IOException {
	String portFromLaunch = System.getProperty("ote.server.broker.uri.port");
	int port = 0;
	if (portFromLaunch != null) {
	try {
	port = Integer.parseInt(portFromLaunch);
	} catch (NumberFormatException ex) {
	}
	}
	if (port == 0) {
	port = PortUtil.getInstance().getValidPort();
	}
	return port;
	}

	@Override
	public void stop() {
	if(messageService != null && nodeInfo != null){
	try {
	messageService.get(nodeInfo).send(OteBaseMessages.OteHostShutdown, service.getServiceID().toString());
	} catch (OseeCoreException e) {
	OseeLog.log(getClass(), Level.SEVERE, e);
	} catch (RemoteException e) {
	OseeLog.log(getClass(), Level.SEVERE, e);
	}
	}
	if (service != null) {
	try {
	service.updateDynamicInfo();
	service.kill();
	service = null;
	} catch (Exception ex) {
	OseeLog.log(getClass(), Level.SEVERE, ex);
	}
	}
	if (brokerService != null) {
	try {
	brokerService.stopGracefully(".", ".", 10000, 500);
	brokerService.stop();
	} catch (Exception ex) {
	OseeLog.log(getClass(), Level.SEVERE, ex);
	}
	}
	if (serviceSideConnector != null) {
	try {
	connectionService.removeConnector(serviceSideConnector);
	} catch (Exception ex) {
	OseeLog.log(getClass(), Level.SEVERE, ex);
	}
	}
	if(oteServerEntry != null) {
	try{
	lookupRegistration.stop();
	taskToCancel.cancel(true);
	} finally {
	Future<OTEMasterServerResult> removeServer = masterServer.removeServer(masterURI, oteServerEntry);
	try {
	removeServer.get(1000, TimeUnit.MILLISECONDS);
	} catch (InterruptedException e) {
	} catch (ExecutionException e) {
	} catch (TimeoutException e) {
	}
	}
	}
	brokerService = null;
	}

	private String getAddress() throws UnknownHostException {
	InetAddress[] all = InetAddress.getAllByName(InetAddress.getLocalHost().getHostName());
	String defaultAddress = all[0].getHostAddress();
	for (InetAddress address : all ) {
	if(!address.isSiteLocalAddress())
	{
	String firstRealLocalAddress = address.getHostAddress();
	if (address instanceof Inet6Address) {
	firstRealLocalAddress = "[" + firstRealLocalAddress + "]";
	}
	return firstRealLocalAddress;
	}
	}
	return defaultAddress;
	}

	private class ListenForHostRequest extends OseeMessagingListener {

	@Override
	public void process(Object message, Map<String, Object> headers, ReplyConnection replyConnection) {
	if (replyConnection.isReplyRequested()) {
	try {
	ByteArrayOutputStream baos = new ByteArrayOutputStream();
	ObjectOutputStream oos = new ObjectOutputStream(baos);
	oos.writeObject(message);
	oos.writeObject(serviceSideConnector.getService());
	replyConnection.send(baos.toByteArray(), null, OteServiceStarterImpl.this);
	} catch (OseeCoreException ex) {
	OseeLog.log(getClass(), Level.SEVERE, ex);
	} catch (IOException ex) {
	OseeLog.log(getClass(), Level.SEVERE, ex);
	}
	}
	}
	}

	@Override
	public void updateServiceInfo(List<ServiceDescriptionPair> serviceDescription) {
	for (Entry<String, Serializable> entry : serviceSideConnector.getProperties().entrySet()) {
	ServiceDescriptionPair pair = new ServiceDescriptionPair();
	if (entry.getKey() != null && entry.getValue() != null) {
	pair.setName(entry.getKey());
	pair.setValue(entry.getValue().toString());
	serviceDescription.add(pair);
	}
	}
	}

	@Override
	public void fail(Throwable th) {
	OseeLog.log(getClass(), Level.SEVERE, th);
	}

	@Override
	public void success() {
	}

	private static class LookupRegistration implements Runnable {

	private final OTEMasterServer masterServer;
	private final OTEServer server;
	private final URI uri;
	private volatile boolean run = true;
	private final OteService service;

	public LookupRegistration(URI uri, OTEMasterServer masterServer, OTEServer server, OteService service) {
	this.masterServer = masterServer;
	this.server = server;
	this.uri = uri;
	this.service = service;
	}

	@Override
	public void run() {
	try{
	if(run){
	server.setConnectedUsers(service.getProperties().getProperty("user_list", "N.A.").toString());
	masterServer.addServer(uri, server);
	}
	} catch (Throwable th){
	th.printStackTrace();
	}
	}

	public void stop(){
	run = false;
	}

	}

	}