1 files changed, 0 insertions, 186 deletions
diff --git a/plugins/org.eclipse.osee.ote.jms/src/org/eclipse/osee/ote/jms/internal/ClientSideConnectionNodeLifecycleController.java b/plugins/org.eclipse.osee.ote.jms/src/org/eclipse/osee/ote/jms/internal/ClientSideConnectionNodeLifecycleController.java
deleted file mode 100644
index a814f830b79..00000000000
--- a/plugins/org.eclipse.osee.ote.jms/src/org/eclipse/osee/ote/jms/internal/ClientSideConnectionNodeLifecycleController.java
+++ /dev/null
@@ -1,186 +0,0 @@
-/*******************************************************************************
- * Copyright (c) 2013 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.jms.internal;
-
-import java.io.Serializable;
-import java.net.InetSocketAddress;
-import java.util.Map.Entry;
-import java.util.logging.Level;
-
-import org.eclipse.osee.connection.service.IServiceConnector;
-import org.eclipse.osee.framework.jdk.core.type.OseeCoreException;
-import org.eclipse.osee.framework.jdk.core.util.EnhancedProperties;
-import org.eclipse.osee.framework.logging.OseeLog;
-import org.eclipse.osee.framework.messaging.ConnectionNode;
-import org.eclipse.osee.framework.messaging.MessageService;
-import org.eclipse.osee.framework.messaging.NodeInfo;
-import org.eclipse.osee.ote.OTEException;
-import org.eclipse.osee.ote.endpoint.OteEndpointUtil;
-import org.eclipse.osee.ote.endpoint.OteUdpEndpoint;
-import org.eclipse.osee.ote.endpoint.OteUdpEndpointSender;
-import org.eclipse.osee.ote.jms.OteServerJmsNodeProvider;
-import org.eclipse.osee.ote.service.ConnectionEvent;
-import org.eclipse.osee.ote.service.IOteClientService;
-import org.eclipse.osee.ote.service.ITestConnectionListener;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
-
-
-
-/**
- * @author Michael P. Masterson
- */
-public final class ClientSideConnectionNodeLifecycleController implements ITestConnectionListener {
-
-   private MessageService messageService;
-   private IOteClientService clientService;
-   private BundleContext context;
-   private ServiceRegistration<?> registration;
-   private OteUdpEndpointSender oteEndpointSender;
-   private OteUdpEndpoint oteEndpoint;
-
-   public void start(BundleContext context) {
-      this.context = context;
-      clientService.addConnectionListener(this);
-
-   }
-
-   public void stop() {
-      clientService.removeConnectionListener(this);
-      unregisterConnectionNode();
-      this.messageService = null;
-      this.clientService = null;
-      this.context = null;
-
-   }
-
-   public void setMessageService(MessageService messageService) {
-      this.messageService = messageService;
-   }
-
-   public void setClientService(IOteClientService clientService) {
-      this.clientService = clientService;
-   }
-   
-   public void bindOteUdpEndpoint(OteUdpEndpoint oteEndpoint) {
-      this.oteEndpoint = oteEndpoint;
-   }
-
-   @Override
-   public void onPostConnect(ConnectionEvent event) {
-      if (context == null) {
-         OseeLog.log(getClass(), Level.SEVERE, "Received a onPostConnect event with a null context.");
-         return;
-      }
-      IServiceConnector connector = event.getConnector();
-      registerConnectionNode(connector);
-   }
-
-   /**
-    * @param connector
-    */
-   private void registerConnectionNode(IServiceConnector connector) {
-      Object obj = connector.getProperty("oteUdpEndpoint", null);
-      if (obj != null) {
-         try{
-            InetSocketAddress address = OteEndpointUtil.getAddress(obj.toString());
-            if(!oteEndpoint.getLocalEndpoint().equals(address)){
-               oteEndpointSender = oteEndpoint.getOteEndpointSender(address);
-               oteEndpoint.addBroadcast(oteEndpointSender);
-            }
-         } catch (OTEException ex){
-            OseeLog.log(getClass(), Level.SEVERE, ex);
-         }
-      } else {
-         obj = connector.getProperty("OTEEmbeddedBroker", null);
-         if (obj != null && obj instanceof NodeInfo) {
-            debug("Registering client connection service");
-            NodeInfo nodeInfo = (NodeInfo) obj;
-            registerConnectionNode(nodeInfo);
-         } else {
-            debug(String.format("Problem using connector...%s:%s", obj.getClass(), obj));
-            EnhancedProperties properties = connector.getProperties();
-            for( Entry<String, Serializable> entry : properties.entrySet() ) {
-               debug(String.format("\t%s = %s", entry.getKey(), entry.getValue()));
-            }
-         }
-      }
-   }
-   
-   /**
-    * @param nodeInfo
-    */
-   private void registerConnectionNode(NodeInfo nodeInfo) {
-      try {
-         ConnectionNode node = messageService.get(nodeInfo);
-         registration =
-               context.registerService(OteServerJmsNodeProvider.class.getName(), new ClientSideConnectionNodeProviderImpl(node), null);
-      } catch (OseeCoreException ex) {
-         OseeLog.log(getClass(), Level.SEVERE, ex);
-      }
-   }
-
-   @Override
-   public void onConnectionLost(IServiceConnector connector) {
-      Object obj = connector.getProperty("oteUdpEndpoint", null);
-      if (obj != null) {
-         try{
-            InetSocketAddress address = OteEndpointUtil.getAddress(obj.toString());
-            if(!oteEndpoint.getLocalEndpoint().equals(address)){
-               oteEndpointSender = oteEndpoint.getOteEndpointSender(address);
-               oteEndpoint.removeBroadcast(oteEndpointSender);
-               oteEndpointSender.stop();
-            }
-         } catch (OTEException ex){
-            OseeLog.log(getClass(), Level.SEVERE, ex);
-         } catch (InterruptedException e) {
-            e.printStackTrace();
-         }
-      } else {
-         unregisterConnectionNode();
-      }
-   }
-
-
-
-   private void unregisterConnectionNode() {
-      if (registration != null) {
-         registration.unregister();
-         registration = null;
-      }
-   }
-
-   @Override
-   public void onPreDisconnect(ConnectionEvent event) {
-      Object obj = event.getConnector().getProperty("oteUdpEndpoint", null);
-      if (obj != null) {
-         try{
-            InetSocketAddress address = OteEndpointUtil.getAddress(obj.toString());
-            if(!oteEndpoint.getLocalEndpoint().equals(address)){
-               oteEndpointSender = oteEndpoint.getOteEndpointSender(address);
-               oteEndpoint.removeBroadcast(oteEndpointSender);
-               oteEndpointSender.stop();
-            }
-         } catch (OTEException ex){
-            OseeLog.log(getClass(), Level.SEVERE, ex);
-         } catch (InterruptedException e) {
-            e.printStackTrace();
-         }
-      } else {
-         unregisterConnectionNode();
-      }
-   }
-
-   private void debug(String msg ) {
-      if( System.getProperty("ote.jms.node.debug") != null )
-         System.out.println(msg);
-   }
-}