commons-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hamm...@apache.org
Subject cvs commit: jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/client/impl/naming DefaultAltrmiContext.java DefaultAltrmiInitialContextFactory.java AltrmiContext.java
Date Sun, 10 Mar 2002 09:40:18 GMT
hammant     02/03/10 01:40:18

  Modified:    altrmi/src/java/org/apache/commons/altrmi/client/impl
                        DefaultInterfaceLookupFactory.java
  Added:       altrmi/src/java/org/apache/commons/altrmi/client/impl/naming
                        DefaultAltrmiContext.java
                        DefaultAltrmiInitialContextFactory.java
  Removed:     altrmi/src/java/org/apache/commons/altrmi/client/impl/naming
                        AltrmiContext.java
  Log:
  Start of JNDI by Vinay
  
  Revision  Changes    Path
  1.3       +9 -1      jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/client/impl/DefaultInterfaceLookupFactory.java
  
  Index: DefaultInterfaceLookupFactory.java
  ===================================================================
  RCS file: /home/cvs/jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/client/impl/DefaultInterfaceLookupFactory.java,v
  retrieving revision 1.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- DefaultInterfaceLookupFactory.java	6 Mar 2002 16:11:02 -0000	1.2
  +++ DefaultInterfaceLookupFactory.java	10 Mar 2002 09:40:18 -0000	1.3
  @@ -20,9 +20,17 @@
    *
    *
    * @author Paul Hammant <a href="mailto:Paul_Hammant@yahoo.com">Paul_Hammant@yahoo.com</a>
  - * @version $Revision: 1.2 $
  + * @version $Revision: 1.3 $
    */
   public class DefaultInterfaceLookupFactory extends AbstractInterfaceLookupFactory {
  +
  +    public static final String[] SUPPORTEDSTREAMS = new String[] {
  +        "SocketObjectStream",
  +        "SocketCustomStream",
  +        "RMI"
  +    };
  +
  +
   
       /**
        * Constructor DefaultInterfaceLookupFactory
  
  
  
  1.1                  jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/client/impl/naming/DefaultAltrmiContext.java
  
  Index: DefaultAltrmiContext.java
  ===================================================================
  
  /*
   * Copyright (C) The Apache Software Foundation. All rights reserved.
   *
   * This software is published under the terms of the Apache Software License
   * version 1.1, a copy of which has been included with this distribution in
   * the LICENSE.txt file.
   */
  package org.apache.commons.altrmi.client.impl.naming;
  
  
  
  import java.util.Hashtable;
  
  import javax.naming.Context;
  import javax.naming.Name;
  import javax.naming.NameParser;
  import javax.naming.NamingEnumeration;
  import javax.naming.NamingException;
  
  import org.apache.commons.altrmi.client.AltrmiInterfaceLookup;
  import org.apache.commons.altrmi.client.AltrmiInterfaceLookupFactory;
  import org.apache.commons.altrmi.client.impl.DefaultInterfaceLookupFactory;
  import org.apache.commons.altrmi.common.AltrmiConnectionException;
  
  
  /**
   * Class DefaultAltrmiContext
   *
   *
   * @author Vinay Chandrasekharan <a href="mailto:vinay_chandran@users.sourceforge.net">vinay_chandran@users.sourceforge.net</a>
   * @version $Revision: 1.1 $
   */
  public class DefaultAltrmiContext implements Context {
  
      AltrmiInterfaceLookupFactory altrmiInterfaceLookupFactory =
          new DefaultInterfaceLookupFactory();
      AltrmiInterfaceLookup altrmiInterfaceLookup = null;
  
      /**
       * Constructor DefaultAltrmiContext
       *
       *
       * @param host
       * @param port
       * @param transportStream
       * @param env
       *
       * @throws NamingException
       *
       */
      DefaultAltrmiContext(String host, String port, String transportStream, Hashtable env)
              throws NamingException {
  
          String proxyDetails = null;
          String beanDetails = null;
  
          proxyDetails = (String) env.get("proxy.type");
          beanDetails = (String) env.get("bean.type");
  
          if (proxyDetails == null) {
              proxyDetails = "S";
          }
  
          if (beanDetails == null) {
              beanDetails = "NBO";
          }
  
          try {
              System.out.println("iurl[" + transportStream + ":" + host + ":" + port + ":"
                                 + proxyDetails + ":" + beanDetails + "]");
  
              altrmiInterfaceLookup =
                  altrmiInterfaceLookupFactory.getAltrmiInterfaceLookup(transportStream +
":"
                                                                        + host + ":" + port
+ ":"
                                                                        + proxyDetails + ":"
                                                                        + beanDetails);
          } catch (AltrmiConnectionException ace) {
              ace.printStackTrace();
  
              throw new NamingException(ace.getMessage());
          }
      }
  
      /**
       * Method lookup
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Object lookup(Name name) throws NamingException {
          return null;
      }
  
      /**
       * Method lookup
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Object lookup(String name) throws NamingException {
  
          try {
              return altrmiInterfaceLookup.lookup(name);
          } catch (AltrmiConnectionException ace) {
              ace.printStackTrace();
  
              throw new NamingException(ace.getMessage());
          }
      }
  
      /**
       * Method bind
       *
       *
       * @param name
       * @param obj
       *
       * @throws NamingException
       *
       */
      public void bind(Name name, Object obj) throws NamingException {}
  
      /**
       * Method bind
       *
       *
       * @param name
       * @param obj
       *
       * @throws NamingException
       *
       */
      public void bind(String name, Object obj) throws NamingException {}
  
      /**
       * Method rebind
       *
       *
       * @param name
       * @param obj
       *
       * @throws NamingException
       *
       */
      public void rebind(Name name, Object obj) throws NamingException {}
  
      /**
       * Method rebind
       *
       *
       * @param name
       * @param obj
       *
       * @throws NamingException
       *
       */
      public void rebind(String name, Object obj) throws NamingException {}
  
      /**
       * Method unbind
       *
       *
       * @param name
       *
       * @throws NamingException
       *
       */
      public void unbind(Name name) throws NamingException {}
  
      /**
       * Method unbind
       *
       *
       * @param name
       *
       * @throws NamingException
       *
       */
      public void unbind(String name) throws NamingException {}
  
      /**
       * Method rename
       *
       *
       * @param oldName
       * @param newName
       *
       * @throws NamingException
       *
       */
      public void rename(Name oldName, Name newName) throws NamingException {}
  
      /**
       * Method rename
       *
       *
       * @param oldName
       * @param newName
       *
       * @throws NamingException
       *
       */
      public void rename(String oldName, String newName) throws NamingException {}
  
      /**
       * Method list
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public NamingEnumeration list(Name name) throws NamingException {
          return null;
      }
  
      /**
       * Method list
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public NamingEnumeration list(String name) throws NamingException {
  
          final String[] names = altrmiInterfaceLookup.list();
  
          return new NamingEnumeration() {
  
              int size = names.length;
              int index = 0;
  
              public void close() {}
  
              public boolean hasMore() {
                  return index < names.length;
              }
  
              public Object next() {
                  return names[index++];
              }
  
              public boolean hasMoreElements() {
                  return hasMore();
              }
  
              public Object nextElement() {
                  return next();
              }
          };
      }
  
      /**
       * Method listBindings
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public NamingEnumeration listBindings(Name name) throws NamingException {
          return null;
      }
  
      /**
       * Method listBindings
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public NamingEnumeration listBindings(String name) throws NamingException {
          return null;
      }
  
      /**
       * Method destroySubcontext
       *
       *
       * @param name
       *
       * @throws NamingException
       *
       */
      public void destroySubcontext(Name name) throws NamingException {}
  
      /**
       * Method destroySubcontext
       *
       *
       * @param name
       *
       * @throws NamingException
       *
       */
      public void destroySubcontext(String name) throws NamingException {}
  
      /**
       * Method createSubcontext
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Context createSubcontext(Name name) throws NamingException {
          return null;
      }
  
      /**
       * Method createSubcontext
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Context createSubcontext(String name) throws NamingException {
          return null;
      }
  
      /**
       * Method lookupLink
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Object lookupLink(Name name) throws NamingException {
          return null;
      }
  
      /**
       * Method lookupLink
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Object lookupLink(String name) throws NamingException {
          return null;
      }
  
      /**
       * Method getNameParser
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public NameParser getNameParser(Name name) throws NamingException {
          return null;
      }
  
      /**
       * Method getNameParser
       *
       *
       * @param name
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public NameParser getNameParser(String name) throws NamingException {
          return null;
      }
  
      /**
       * Method composeName
       *
       *
       * @param name
       * @param prefix
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Name composeName(Name name, Name prefix) throws NamingException {
          return null;
      }
  
      /**
       * Method composeName
       *
       *
       * @param name
       * @param prefix
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public String composeName(String name, String prefix) throws NamingException {
          return null;
      }
  
      /**
       * Method addToEnvironment
       *
       *
       * @param propName
       * @param propVal
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Object addToEnvironment(String propName, Object propVal) throws NamingException
{
          return null;
      }
  
      /**
       * Method removeFromEnvironment
       *
       *
       * @param propName
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Object removeFromEnvironment(String propName) throws NamingException {
          return null;
      }
  
      /**
       * Method getEnvironment
       *
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public Hashtable getEnvironment() throws NamingException {
          return null;
      }
  
      /**
       * Method close
       *
       *
       * @throws NamingException
       *
       */
      public void close() throws NamingException {
          altrmiInterfaceLookup.close();
      }
  
      /**
       * Method getNameInNamespace
       *
       *
       * @return
       *
       * @throws NamingException
       *
       */
      public String getNameInNamespace() throws NamingException {
          return null;
      }
  }
  
  
  
  1.1                  jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/client/impl/naming/DefaultAltrmiInitialContextFactory.java
  
  Index: DefaultAltrmiInitialContextFactory.java
  ===================================================================
  
  /*
   * Copyright (C) The Apache Software Foundation. All rights reserved.
   *
   * This software is published under the terms of the Apache Software License
   * version 1.1, a copy of which has been included with this distribution in
   * the LICENSE.txt file.
   */
  package org.apache.commons.altrmi.client.impl.naming;
  
  
  
  import java.util.Hashtable;
  
  import javax.naming.Context;
  import javax.naming.NamingException;
  import javax.naming.spi.InitialContextFactory;
  
  import org.apache.commons.altrmi.client.impl.DefaultInterfaceLookupFactory;
  
  
  /**
   * Class DefaultAltrmiInitialContextFactory
   *
   *
   * @author Vinay Chandrasekharan <a href="mailto:vinay_chandran@users.sourceforge.net">vinay_chandran@users.sourceforge.net</a>
   * @version $Revision: 1.1 $
   */
  public class DefaultAltrmiInitialContextFactory implements InitialContextFactory {
  
      /**
       * Method getInitialContext
       *
       *
       * @param env
       *
       * @return
       *
       * @throws NamingException
       *
       * @see InitialContextFactory#getInitialContext(Hashtable)
       *
       */
      public Context getInitialContext(Hashtable env) throws NamingException {
  
          String transportStream = "";
          String s_url = (String) env.get(Context.PROVIDER_URL);
          int index = -1;
  
          index = (s_url.lastIndexOf("\\") > s_url.lastIndexOf("/"))
                  ? s_url.lastIndexOf("\\") : s_url.lastIndexOf("/");
          transportStream = s_url.substring(index + 1);
  
          System.out.println("transportStream[" + transportStream + "]");
  
          for (int i = 0; i < DefaultInterfaceLookupFactory.SUPPORTEDSTREAMS.length; i++)
{
              if (transportStream
                      .equalsIgnoreCase(DefaultInterfaceLookupFactory.SUPPORTEDSTREAMS[i]))
{
                  String host = s_url.substring(s_url.indexOf(":") + 3, s_url.lastIndexOf(":"));
                  String port = s_url.substring(s_url.lastIndexOf(":") + 1, index);
  
                  return new DefaultAltrmiContext(host, port, transportStream, env);
              }
          }
  
          throw new NamingException("TransportStream[" + transportStream + "] not supported");
      }
  }
  
  
  

--
To unsubscribe, e-mail:   <mailto:commons-dev-unsubscribe@jakarta.apache.org>
For additional commands, e-mail: <mailto:commons-dev-help@jakarta.apache.org>


Mime
View raw message