Source code: com/mjh/switchrmi/RmiContextImpl.java

   //
   // SwitchRMI  Framework
   // Copyright (c) 2000-2002 by Michael J. Henderson & Associates.
   //
   // Michael Henderson
   // http://switchrmi.sf.net
   // mailto:mikehenderson@dunelm.org.uk
   //
   // This library is free software.
  //
  // You may redistribute it and/or modify it under the terms of the GNU
  // Lesser General Public License as published by the Free Software Foundation.
  //
  // Version 2.1 of the license should be included with this distribution in
  // the file LICENSE, as well as License.html. If the license is not
  // included with this distribution, you may find a copy at the FSF web
  // site at 'www.gnu.org' or 'www.fsf.org', or you may write to the
  // Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139 USA.
  //
  // This library is distributed in the hope that it will be useful,
  // but WITHOUT ANY WARRANTY; without even the implied waranty of
  // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  // Lesser General Public License for more details.
  //
  // $Id: RmiContextImpl.java,v 1.1 2002/11/11 22:19:48 mikehenderson Exp $
  package com.mjh.switchrmi;
  
  import com.mjh.util.*;
  
  import java.net.*;
  
  import java.util.*;
  
  import javax.naming.*;
  
  import org.apache.log4j.*;
  
  public class RmiContextImpl implements RmiContext
  {
      private static final Logger log = 
              Logger.getLogger(RmiContext.class.getName());
      private String targetUrl;
      private RmiTransport transport;
      private RmiProtocol protocol;
      private UrlInfo urlInfo;
      private Object sessionID;
      private Object target;
      private Context jndiContext;
      boolean isService;
  
      public RmiContextImpl()
      {
      }
  
      public RmiContextImpl(boolean isService)
      {
          this.isService = isService;
      }
  
      public RmiContextImpl(boolean isService, String url, Context ctx)
                     throws Exception
      {
          this(isService, url, ctx, null);
      }
  
      public RmiContextImpl(boolean isService, String url, Context ctx, 
                            String protocolName)
                     throws Exception
      {
          this.isService = isService;
          setUrl(url);
          urlInfo = new RmiUrlInfo(url);
  
          if (log.isDebugEnabled())
          {
              log.debug("urlInfo = " + urlInfo);
          }
  
          jndiContext = ctx;
  
          String string = (isService()) ? "service/" : "client/";
          String jndiName = "/switchrmi/" + string + "transport/"
                            + getTransportName();
  
          if (log.isDebugEnabled())
          {
              log.debug("jndiName = " + jndiName);
          }
  
          transport = (RmiTransport) ctx.lookup(jndiName);
  
          if (log.isDebugEnabled())
          {
              log.debug("transport = " + transport);
          }
  
          if (log.isDebugEnabled())
          {
              log.debug("protocolName = " + protocolName);
             log.debug("getProtocolName() = " + getProtocolName());
         }
 
         String name = (protocolName == null
                       || protocolName.trim().length() == 0)
                       ? getProtocolName() : protocolName;
 
         jndiName = "/switchrmi/" + string + "protocol/" + name;
 
         if (log.isDebugEnabled())
         {
             log.debug("jndiName = " + jndiName);
         }
 
         protocol = (RmiProtocol) ctx.lookup(jndiName);
 
         if (log.isDebugEnabled())
         {
             log.debug("protocol = " + protocol);
         }
     }
 
     public boolean isClient()
     {
         return !isService;
     }
 
     public boolean isService()
     {
         return isService;
     }
 
     public void setUrl(String url)
     {
         targetUrl = url;
     }
 
     public String getUrl()
     {
         return targetUrl;
     }
 
     public void setTransport(RmiTransport transport)
     {
         this.transport = transport;
     }
 
     public RmiTransport getTransport()
     {
         return transport;
     }
 
     public void setProtocol(RmiProtocol protocol)
     {
         this.protocol = protocol;
     }
 
     public RmiProtocol getProtocol()
     {
         return protocol;
     }
 
     public String getObjectName()
     {
         return ((RmiUrlInfo) urlInfo).getObjectName();
     }
 
     public String getTransportName()
     {
         return ((RmiUrlInfo) urlInfo).getTransportName();
     }
 
     public String getProtocolName()
     {
         return ((RmiUrlInfo) urlInfo).getProtocolName();
     }
 
     public void setTarget(Object target)
     {
         this.target = target;
     }
 
     public Object lookup(String name)
                   throws Exception
     {
         return jndiContext.lookup(name);
     }
 
     public Context getJndiContext()
     {
         return jndiContext;
     }
 
     public Object getTarget()
     {
         return target;
     }
 
     public void setSessionIdentifier(Object identifier)
     {
         sessionID = identifier;
 
         if (log.isDebugEnabled())
         {
             log.debug("context.setSessionIdentifier() sessionID = " + sessionID);
         }
     }
 
     public Object getSessionIdentifier()
     {
         if (log.isDebugEnabled())
         {
             log.debug("context.getSessionIdentifier() sessionID = " + sessionID);
         }
 
         return sessionID;
     }
 
     public UrlInfo getUrlInfo()
                        throws MalformedURLException
     {
         return getTransport().getUrlInfo(this);
     }
 }