unsubscribe from this list?
and before you send some smart alec response like follow the link, realize
that at the end of the link there is no info on unsubscribing.
thanks,
Dave Blankley
-- Original Message --
>Send Jboss-development mailing list submissions to
> [EMAIL PROTECTED]
>
>To subscribe or unsubscribe via the World Wide Web, visit
> http://lists.sourceforge.net/lists/listinfo/jboss-development
>or, via email, send a message with subject or body 'help' to
> [EMAIL PROTECTED]
>
>You can reach the person managing the list at
> [EMAIL PROTECTED]
>
>When replying, please edit your Subject line so it is more specific
>than "Re: Contents of Jboss-development digest..."
>
>
>Today's Topics:
>
> 1. CVS update: jboss/src/client jnp-client.jar (Scott M Stark)
> 2. CVS update: jboss/src/lib jnpserver.jar (Scott M Stark)
> 3. CVS update: jboss/src/main/org/jboss Main.java (Scott M Stark)
> 4. CVS update: jboss/src/main/org/jboss/ejb/plugins/jrmp/server
>DefaultSocketFactory.java
>JRMPContainerInvoker.java (Scott M Stark)
>
>--__--__--
>
>Message: 1
>To: [EMAIL PROTECTED]
>From: Scott M Stark <[EMAIL PROTECTED]>
>Date: Thu, 19 Jul 2001 13:13:07 -0700
>Subject: [JBoss-dev] CVS update: jboss/src/client jnp-client.jar
>Reply-To: [EMAIL PROTECTED]
>
> User: starksm
> Date: 01/07/19 13:13:07
>
> Modified: src/client Tag: Branch_2_4 jnp-client.jar
> Log:
> Add support for binding the JRMP/RMI objects on a specific address
> Integrate the jnp changes to support binding the name service on a specific
>address
>
> Revision Changes Path
> No revision
>
>
> No revision
>
>
> 1.11.4.2 +21 -21 jboss/src/client/jnp-client.jar
>
> <<Binary file>>
>
>
>
>
>--__--__--
>
>Message: 2
>To: [EMAIL PROTECTED]
>From: Scott M Stark <[EMAIL PROTECTED]>
>Date: Thu, 19 Jul 2001 13:13:07 -0700
>Subject: [JBoss-dev] CVS update: jboss/src/lib jnpserver.jar
>Reply-To: [EMAIL PROTECTED]
>
> User: starksm
> Date: 01/07/19 13:13:07
>
> Modified: src/lib Tag: Branch_2_4 jnpserver.jar
> Log:
> Add support for binding the JRMP/RMI objects on a specific address
> Integrate the jnp changes to support binding the name service on a specific
>address
>
> Revision Changes Path
> No revision
>
>
> No revision
>
>
> 1.13.4.2 +40 -34 jboss/src/lib/jnpserver.jar
>
> <<Binary file>>
>
>
>
>
>--__--__--
>
>Message: 3
>To: [EMAIL PROTECTED]
>From: Scott M Stark <[EMAIL PROTECTED]>
>Date: Thu, 19 Jul 2001 13:13:07 -0700
>Subject: [JBoss-dev] CVS update: jboss/src/main/org/jboss Main.java
>Reply-To: [EMAIL PROTECTED]
>
> User: starksm
> Date: 01/07/19 13:13:07
>
> Modified: src/main/org/jboss Tag: Branch_2_4 Main.java
> Log:
> Add support for binding the JRMP/RMI objects on a specific address
> Integrate the jnp changes to support binding the name service on a specific
>address
>
> Revision Changes Path
> No revision
>
>
> No revision
>
>
> 1.35.2.5 +241 -241 jboss/src/main/org/jboss/Main.java
>
> Index: Main.java
> ===================================================================
> RCS file: /cvsroot/jboss/jboss/src/main/org/jboss/Main.java,v
> retrieving revision 1.35.2.4
> retrieving revision 1.35.2.5
> diff -u -r1.35.2.4 -r1.35.2.5
> --- Main.java 2001/07/09 08:33:26 1.35.2.4
> +++ Main.java 2001/07/19 20:13:07 1.35.2.5
> @@ -1,242 +1,242 @@
> -/*
> - * JBoss, the OpenSource EJB server
> - *
> - * Distributable under LGPL license.
> - * See terms of license at gnu.org.
> - */
> -
> -package org.jboss;
> -
> -import java.io.File;
> -import java.io.IOException;
> -import java.io.InputStream;
> -import java.io.PrintStream;
> -import java.io.BufferedReader;
> -import java.io.InputStreamReader;
> -import java.io.PrintWriter;
> -import java.io.FileWriter;
> -import java.net.URL;
> -import java.security.*;
> -import java.util.*;
> -
> -import javax.management.*;
> -import javax.management.loading.*;
> -
> -/**
> - *
> - * @see <related>
> - * @author Rickard �berg ([EMAIL PROTECTED])
> - * @author <a href="mailto:[EMAIL PROTECTED]";>Daniel O'Connor</a>.
> - * @author [EMAIL PROTECTED]
> - * @version $Revision: 1.35.2.4 $
> - */
> -public class Main
> -{
> - // Constants -----------------------------------------------------
> -
> - String versionIdentifier = "2.4 BETA(Rel_2_4_0_14)";
> - // Attributes ----------------------------------------------------
> -
> - // Static --------------------------------------------------------
> - public static void main(final String[] args)
> - throws Exception
> - {
> +/*
> + * JBoss, the OpenSource EJB server
> + *
> + * Distributable under LGPL license.
> + * See terms of license at gnu.org.
> + */
> +
> +package org.jboss;
> +
> +import java.io.File;
> +import java.io.IOException;
> +import java.io.InputStream;
> +import java.io.PrintStream;
> +import java.io.BufferedReader;
> +import java.io.InputStreamReader;
> +import java.io.PrintWriter;
> +import java.io.FileWriter;
> +import java.net.URL;
> +import java.security.*;
> +import java.util.*;
> +
> +import javax.management.*;
> +import javax.management.loading.*;
> +
> +/**
> + *
> + * @see <related>
> + * @author Rickard �berg ([EMAIL PROTECTED])
> + * @author <a href="mailto:[EMAIL PROTECTED]";>Daniel O'Connor</a>.
> + * @author [EMAIL PROTECTED]
> + * @version $Revision: 1.35.2.5 $
> + */
> +public class Main
> +{
> + // Constants -----------------------------------------------------
> +
> + String versionIdentifier = "2.4 BETA(Rel_2_4_0_23)";
> + // Attributes ----------------------------------------------------
> +
> + // Static --------------------------------------------------------
> + public static void main(final String[] args)
> + throws Exception
> + {
> Thread.currentThread().setName("JBossMain");
> - String cn = "default"; // Default configuration name is "default",
>i.e. all conf files are in "/conf/default"
> - String patchDir = null;
> - // Given conf name?
> - if (args.length == 1)
> - cn = args[0];
> - for(int a = 0; a < args.length; a ++)
> - {
> - if( args[a].startsWith("-p") )
> - patchDir = args[a+1];
> - }
> - final String confName = cn;
> - final String patchDirName = patchDir;
> -
> - // Load system properties
> - URL jbossProps =
>Main.class.getClassLoader().getResource(confName+"/jboss.properties");
> - InputStream propertiesIn =
>Main.class.getClassLoader().getResourceAsStream(confName+"/jboss.properties");
> - if ( propertiesIn == null )
> - {
> - throw new IOException("jboss.properties missing");
> - }
> -
> - System.getProperties().load(propertiesIn);
> -
> - /* Set a jboss.home property from the location of the Main.class
>jar
> - if the property does not exist.
> - */
> - if( System.getProperty("jboss.home") == null )
> - {
> - String path =
>Main.class.getProtectionDomain().getCodeSource().getLocation().getFile();
> - File runJar = new File(path);
> - // Home dir should be the parent of the dir containing run.jar
> - File homeDir = new File(runJar.getParent(), "..");
> - System.setProperty("jboss.home", homeDir.getCanonicalPath());
> - }
> - System.out.println("jboss.home = "+System.getProperty("jboss.home"));
> -
> - // Set the JAAS login config file if not already set
> - if( System.getProperty("java.security.auth.login.config") == null
>)
> - {
> - URL loginConfig =
>Main.class.getClassLoader().getResource(confName+"/auth.conf");
> - if( loginConfig != null )
> - {
> - System.setProperty("java.security.auth.login.config",
loginConfig.toExternalForm());
> - System.out.println("Using JAAS LoginConfig:
>"+loginConfig.toExternalForm());
> - }
> - else
> - {
> - System.out.println("Warning: no auth.conf found in
>config="+confName);
> - }
> - }
> -
> - // Set security
> - URL serverPolicy =
>Main.class.getClassLoader().getResource(confName+"/server.policy");
> -
> - if ( serverPolicy == null )
> - {
> - throw new IOException("server.policy missing");
> - }
> -
> - System.setProperty("java.security.policy", serverPolicy.getFile());
> -
> - // Set security manager
> - // Optional for better performance
> - if (System.getProperty("java.security.manager") != null)
> -
>System.setSecurityManager((SecurityManager)Class.forName(System.getProperty("java.security.manager")).newInstance());
> -
> - // Start server - Main does not have the proper permissions
> - AccessController.doPrivileged(new PrivilegedAction()
> - {
> - public Object run()
> - {
> - new Main(confName, patchDirName);
> - return null;
> - }
> - });
> - }
> -
> - // Constructors --------------------------------------------------
> - public Main(String confName, String patchDir)
> - {
> - Date startTime = new Date();
> -
> - try
> - {
> - System.out.println("Using configuration \""+confName+"\"");
> -
> - final PrintStream err = System.err;
> -
> - com.sun.management.jmx.Trace.parseTraceProperties();
> -
> - // Give feedback about from where jndi.properties is read
> - URL jndiLocation = this.getClass().getResource("/jndi.properties");
> - if (jndiLocation instanceof URL) {
> - System.out.println("Please make sure the following is intended
>(check your CLASSPATH):");
> - System.out.println(" jndi.properties is read from "+jndiLocation);
> - }
> -
> - // Create MBeanServer
> - final MBeanServer server = MBeanServerFactory.createMBeanServer();
> -
> - // Add configuration directory to MLet
> - URL confDirectory = new
>File("../conf/"+confName).getCanonicalFile().toURL();
> - URL[] urls = {confDirectory};
> - // Add any patch jars to the MLet so they are seen ahead of
>the JBoss jars
> - if( patchDir != null )
> - {
> - File dir = new File(patchDir);
> - ArrayList tmp = new ArrayList();
> - File[] jars = dir.listFiles(new java.io.FileFilter()
> - {
> - public boolean accept(File pathname)
> - {
> - String name = pathname.getName();
> - return name.endsWith(".jar") || name.endsWith(".zip");
> - }
> - }
> - );
> - tmp.add(confDirectory);
> - for(int j = 0; jars != null && j < jars.length; j ++)
> - {
> - File jar = jars[j];
> - URL u = jar.getCanonicalFile().toURL();
> - tmp.add(u);
> - }
> - urls = new URL[tmp.size()];
> - tmp.toArray(urls);
> - }
> -
> - // Create MLet
> - MLet mlet = new MLet(urls);
> - server.registerMBean(mlet, new ObjectName(server.getDefaultDomain(),
>"service", "MLet"));
> -
> - // Set MLet as classloader for this app
> - Thread.currentThread().setContextClassLoader(mlet);
> -
> - // Load configuration
> - URL mletConf = mlet.getResource("jboss.conf");
> - Set beans = (Set)mlet.getMBeansFromURL(mletConf);
> - Iterator enum = beans.iterator();
> - while (enum.hasNext())
> - {
> - Object obj = enum.next();
> - if (obj instanceof RuntimeOperationsException)
> -
>((RuntimeOperationsException)obj).getTargetException().printStackTrace(err);
> - else if (obj instanceof RuntimeErrorException)
> - ((RuntimeErrorException)obj).getTargetError().printStackTrace(err);
> - else if (obj instanceof MBeanException)
> - ((MBeanException)obj).getTargetException().printStackTrace(err);
> - else if (obj instanceof RuntimeMBeanException)
> -
>((RuntimeMBeanException)obj).getTargetException().printStackTrace(err);
> - else if (obj instanceof ReflectionException)
> -
>((ReflectionException)obj).getTargetException().printStackTrace(err);
> - else if (obj instanceof Throwable)
> - ((Throwable)obj).printStackTrace(err);
> - }
> -
> - // Load configuration
> - server.invoke(new ObjectName(":service=Configuration"),
>"loadConfiguration",
>new Object[0], new String[0]);
> -
> - // Store configuration
> - // This way, the config will always contain a complete mirror
>of what's in the server
> - server.invoke(new ObjectName(":service=Configuration"),
>"saveConfiguration",
>new Object[0] , new String[0]);
> -
> - // Init and Start MBeans
> - server.invoke(new ObjectName(":service=ServiceControl"), "init",
>new Object[0] , new String[0]);
> - server.invoke(new ObjectName(":service=ServiceControl"), "start",
>new Object[0] , new String[0]);
> -
> - }
> - catch (RuntimeOperationsException e)
> - {
> - System.out.println("Runtime error");
> - e.getTargetException().printStackTrace();
> - }
> - catch (RuntimeErrorException e)
> - {
> - System.out.println("Runtime error");
> - e.getTargetError().printStackTrace();
> - }
> - catch (MBeanException e)
> - {
> - e.getTargetException().printStackTrace();
> - }
> - catch (RuntimeMBeanException e)
> - {
> - e.getTargetException().printStackTrace();
> - }
> - catch (Exception e)
> - {
> - e.printStackTrace();
> - }
> -
> - // Done
> - Date stopTime = new Date();
> - Date lapsedTime = new Date(stopTime.getTime()-startTime.getTime());
> - System.out.println("JBoss "+versionIdentifier+" Started in
>"+lapsedTime.getMinutes()+"m:"+lapsedTime.getSeconds()+"s");
> - }
> -}
> -
> + String cn = "default"; // Default configuration name is "default",
>i.e. all conf files are in "/conf/default"
> + String patchDir = null;
> + // Given conf name?
> + if (args.length == 1)
> + cn = args[0];
> + for(int a = 0; a < args.length; a ++)
> + {
> + if( args[a].startsWith("-p") )
> + patchDir = args[a+1];
> + }
> + final String confName = cn;
> + final String patchDirName = patchDir;
> +
> + // Load system properties
> + URL jbossProps =
>Main.class.getClassLoader().getResource(confName+"/jboss.properties");
> + InputStream propertiesIn =
>Main.class.getClassLoader().getResourceAsStream(confName+"/jboss.properties");
> + if ( propertiesIn == null )
> + {
> + throw new IOException("jboss.properties missing");
> + }
> +
> + System.getProperties().load(propertiesIn);
> +
> + /* Set a jboss.home property from the location of the Main.class
>jar
> + if the property does not exist.
> + */
> + if( System.getProperty("jboss.home") == null )
> + {
> + String path =
>Main.class.getProtectionDomain().getCodeSource().getLocation().getFile();
> + File runJar = new File(path);
> + // Home dir should be the parent of the dir containing run.jar
> + File homeDir = new File(runJar.getParent(), "..");
> + System.setProperty("jboss.home", homeDir.getCanonicalPath());
> + }
> + System.out.println("jboss.home = "+System.getProperty("jboss.home"));
> +
> + // Set the JAAS login config file if not already set
> + if( System.getProperty("java.security.auth.login.config") == null
>)
> + {
> + URL loginConfig =
>Main.class.getClassLoader().getResource(confName+"/auth.conf");
> + if( loginConfig != null )
> + {
> + System.setProperty("java.security.auth.login.config",
loginConfig.toExternalForm());
> + System.out.println("Using JAAS LoginConfig:
>"+loginConfig.toExternalForm());
> + }
> + else
> + {
> + System.out.println("Warning: no auth.conf found in
>config="+confName);
> + }
> + }
> +
> + // Set security
> + URL serverPolicy =
>Main.class.getClassLoader().getResource(confName+"/server.policy");
> +
> + if ( serverPolicy == null )
> + {
> + throw new IOException("server.policy missing");
> + }
> +
> + System.setProperty("java.security.policy", serverPolicy.getFile());
> +
> + // Set security manager
> + // Optional for better performance
> + if (System.getProperty("java.security.manager") != null)
> +
>System.setSecurityManager((SecurityManager)Class.forName(System.getProperty("java.security.manager")).newInstance());
> +
> + // Start server - Main does not have the proper permissions
> + AccessController.doPrivileged(new PrivilegedAction()
> + {
> + public Object run()
> + {
> + new Main(confName, patchDirName);
> + return null;
> + }
> + });
> + }
> +
> + // Constructors --------------------------------------------------
> + public Main(String confName, String patchDir)
> + {
> + Date startTime = new Date();
> +
> + try
> + {
> + System.out.println("Using configuration \""+confName+"\"");
> +
> + final PrintStream err = System.err;
> +
> + com.sun.management.jmx.Trace.parseTraceProperties();
> +
> + // Give feedback about from where jndi.properties is read
> + URL jndiLocation = this.getClass().getResource("/jndi.properties");
> + if (jndiLocation instanceof URL) {
> + System.out.println("Please make sure the following is intended
>(check your CLASSPATH):");
> + System.out.println(" jndi.properties is read from "+jndiLocation);
> + }
> +
> + // Create MBeanServer
> + final MBeanServer server = MBeanServerFactory.createMBeanServer();
> +
> + // Add configuration directory to MLet
> + URL confDirectory = new
>File("../conf/"+confName).getCanonicalFile().toURL();
> + URL[] urls = {confDirectory};
> + // Add any patch jars to the MLet so they are seen ahead of
>the JBoss jars
> + if( patchDir != null )
> + {
> + File dir = new File(patchDir);
> + ArrayList tmp = new ArrayList();
> + File[] jars = dir.listFiles(new java.io.FileFilter()
> + {
> + public boolean accept(File pathname)
> + {
> + String name = pathname.getName();
> + return name.endsWith(".jar") || name.endsWith(".zip");
> + }
> + }
> + );
> + tmp.add(confDirectory);
> + for(int j = 0; jars != null && j < jars.length; j ++)
> + {
> + File jar = jars[j];
> + URL u = jar.getCanonicalFile().toURL();
> + tmp.add(u);
> + }
> + urls = new URL[tmp.size()];
> + tmp.toArray(urls);
> + }
> +
> + // Create MLet
> + MLet mlet = new MLet(urls);
> + server.registerMBean(mlet, new ObjectName(server.getDefaultDomain(),
>"service", "MLet"));
> +
> + // Set MLet as classloader for this app
> + Thread.currentThread().setContextClassLoader(mlet);
> +
> + // Load configuration
> + URL mletConf = mlet.getResource("jboss.conf");
> + Set beans = (Set)mlet.getMBeansFromURL(mletConf);
> + Iterator enum = beans.iterator();
> + while (enum.hasNext())
> + {
> + Object obj = enum.next();
> + if (obj instanceof RuntimeOperationsException)
> +
>((RuntimeOperationsException)obj).getTargetException().printStackTrace(err);
> + else if (obj instanceof RuntimeErrorException)
> + ((RuntimeErrorException)obj).getTargetError().printStackTrace(err);
> + else if (obj instanceof MBeanException)
> + ((MBeanException)obj).getTargetException().printStackTrace(err);
> + else if (obj instanceof RuntimeMBeanException)
> +
>((RuntimeMBeanException)obj).getTargetException().printStackTrace(err);
> + else if (obj instanceof ReflectionException)
> +
>((ReflectionException)obj).getTargetException().printStackTrace(err);
> + else if (obj instanceof Throwable)
> + ((Throwable)obj).printStackTrace(err);
> + }
> +
> + // Load configuration
> + server.invoke(new ObjectName(":service=Configuration"),
>"loadConfiguration",
>new Object[0], new String[0]);
> +
> + // Store configuration
> + // This way, the config will always contain a complete mirror
>of what's in the server
> + server.invoke(new ObjectName(":service=Configuration"),
>"saveConfiguration",
>new Object[0] , new String[0]);
> +
> + // Init and Start MBeans
> + server.invoke(new ObjectName(":service=ServiceControl"), "init",
>new Object[0] , new String[0]);
> + server.invoke(new ObjectName(":service=ServiceControl"), "start",
>new Object[0] , new String[0]);
> +
> + }
> + catch (RuntimeOperationsException e)
> + {
> + System.out.println("Runtime error");
> + e.getTargetException().printStackTrace();
> + }
> + catch (RuntimeErrorException e)
> + {
> + System.out.println("Runtime error");
> + e.getTargetError().printStackTrace();
> + }
> + catch (MBeanException e)
> + {
> + e.getTargetException().printStackTrace();
> + }
> + catch (RuntimeMBeanException e)
> + {
> + e.getTargetException().printStackTrace();
> + }
> + catch (Exception e)
> + {
> + e.printStackTrace();
> + }
> +
> + // Done
> + Date stopTime = new Date();
> + Date lapsedTime = new Date(stopTime.getTime()-startTime.getTime());
> + System.out.println("JBoss "+versionIdentifier+" Started in
>"+lapsedTime.getMinutes()+"m:"+lapsedTime.getSeconds()+"s");
> + }
> +}
> +
>
>
>
>
>
>--__--__--
>
>Message: 4
>To: [EMAIL PROTECTED]
>From: Scott M Stark <[EMAIL PROTECTED]>
>Date: Thu, 19 Jul 2001 13:13:07 -0700
>Subject: [JBoss-dev] CVS update: jboss/src/main/org/jboss/ejb/plugins/jrmp/server
>DefaultSocketFactory.java JRMPContainerInvoker.java
>Reply-To: [EMAIL PROTECTED]
>
> User: starksm
> Date: 01/07/19 13:13:07
>
> Modified: src/main/org/jboss/ejb/plugins/jrmp/server Tag: Branch_2_4
> JRMPContainerInvoker.java
> Added: src/main/org/jboss/ejb/plugins/jrmp/server Tag: Branch_2_4
> DefaultSocketFactory.java
> Log:
> Add support for binding the JRMP/RMI objects on a specific address
> Integrate the jnp changes to support binding the name service on a specific
>address
>
> Revision Changes Path
> No revision
>
>
> No revision
>
>
> 1.37.4.1 +62 -18
>jboss/src/main/org/jboss/ejb/plugins/jrmp/server/JRMPContainerInvoker.java
>
> Index: JRMPContainerInvoker.java
> ===================================================================
> RCS file:
>/cvsroot/jboss/jboss/src/main/org/jboss/ejb/plugins/jrmp/server/JRMPContainerInvoker.java,v
> retrieving revision 1.37
> retrieving revision 1.37.4.1
> diff -u -r1.37 -r1.37.4.1
> --- JRMPContainerInvoker.java 2001/05/02 03:04:15 1.37
> +++ JRMPContainerInvoker.java 2001/07/19 20:13:07 1.37.4.1
> @@ -12,6 +12,7 @@
> import java.io.IOException;
> import java.lang.reflect.Method;
> import java.lang.reflect.Constructor;
> +import java.net.UnknownHostException;
> import java.rmi.ServerException;
> import java.rmi.RemoteException;
> import java.rmi.MarshalledObject;
> @@ -69,14 +70,13 @@
> import org.w3c.dom.Element;
>
> /**
> - * <description>
> *
> - * @see <related>
> - * @author Rickard �berg ([EMAIL PROTECTED])
> - * @author <a href="mailto:[EMAIL PROTECTED]";>Sebastien
>Alborini</a>
> - * @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
> - * @author <a href="mailto:[EMAIL PROTECTED]";>Juha Lindfors</a>
> - * @version $Revision: 1.37 $
> + * @author Rickard �berg ([EMAIL PROTECTED])
> + * @author <a href="mailto:[EMAIL PROTECTED]";>Sebastien Alborini</a>
> + * @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
> + * @author <a href="mailto:[EMAIL PROTECTED]";>Juha Lindfors</a>
> + * @author <a href="mailto:[EMAIL PROTECTED]";>Scott Stark</a>
> + * @version $Revision: 1.37.4.1 $
> */
> public class JRMPContainerInvoker
> extends RemoteServer
> @@ -97,6 +97,8 @@
> protected String clientSocketFactoryName;
> /** The class name of the optional custom server socket factory */
> protected String serverSocketFactoryName;
> + /** The address to bind the rmi port on */
> + protected String serverAddress;
> protected boolean jdk122 = false;
> protected Container container;
> protected String jndiName;
> @@ -176,7 +178,8 @@
>
> // Hash it
> homeMethodInvokerMap.put(new
>Long(RemoteMethodInvocation.calculateHash(getEJBObjectMethod)),getEJBObjectMethod);
> - } catch (Exception e)
> + }
> + catch (Exception e)
> {
> Logger.exception(e);
> }
> @@ -254,7 +257,7 @@
> }
>
> public void start()
> - throws Exception
> + throws Exception
> {
> try
> {
> @@ -354,7 +357,7 @@
> * Invoke a Home interface method.
> */
> public MarshalledObject invokeHome(MarshalledObject mimo)
> - throws Exception
> + throws Exception
> {
> ClassLoader oldCl = Thread.currentThread().getContextClassLoader();
> Thread.currentThread().setContextClassLoader(container.getClassLoader());
> @@ -376,7 +379,7 @@
> * Invoke a Remote interface method.
> */
> public MarshalledObject invoke(MarshalledObject mimo)
> - throws Exception
> + throws Exception
> {
> ClassLoader oldCl = Thread.currentThread().getContextClassLoader();
> Thread.currentThread().setContextClassLoader(container.getClassLoader());
> @@ -401,7 +404,7 @@
> */
> public Object invokeHome(Method m, Object[] args, Transaction tx,
> Principal identity, Object credential)
> - throws Exception
> + throws Exception
> {
> // Check if this call really can be optimized
> if
>(!m.getDeclaringClass().isAssignableFrom(((ContainerInvokerContainer)container).getHomeClass()))
> @@ -445,7 +448,7 @@
> */
> public Object invoke(Object id, Method m, Object[] args, Transaction
>tx,
> Principal identity, Object credential )
> - throws Exception
> + throws Exception
> {
> // Check if this call really can be optimized
> // If parent of callers classloader is != parent of our classloader
>-> not optimizable!
> @@ -478,7 +481,8 @@
> try
> {
> return container.invoke(new MethodInvocation(id, m, args, tx,
>identity, credential));
> - } finally
> + }
> + finally
> {
> Thread.currentThread().setContextClassLoader(oldCl);
> }
> @@ -518,10 +522,12 @@
> String port = MetaData.getElementContent(portElement);
> rmiPort = Integer.parseInt(port);
> }
> - } catch(NumberFormatException e)
> + }
> + catch(NumberFormatException e)
> {
> rmiPort = ANONYMOUS_PORT;
> - } catch(DeploymentException e)
> + }
> + catch(DeploymentException e)
> {
> rmiPort = ANONYMOUS_PORT;
> }
> @@ -554,11 +560,15 @@
> Logger.error(e);
> serverSocketFactoryName = null;
> }
> + Element addrElement = MetaData.getOptionalChild(element,
>"RMIServerSocketAddr");
> + if( addrElement != null )
> + this.serverAddress = MetaData.getElementContent(addrElement);
> loadCustomSocketFactories(loader);
>
> Logger.debug("Container Invoker RMI Port='"+(rmiPort == ANONYMOUS_PORT
>? "Anonymous" : Integer.toString(rmiPort))+"'");
> Logger.debug("Container Invoker Client
>SocketFactory='"+(clientSocketFactory
>== null ? "Default" : clientSocketFactory.toString())+"'");
> Logger.debug("Container Invoker Server
>SocketFactory='"+(serverSocketFactory
>== null ? "Default" : serverSocketFactory.toString())+"'");
> + Logger.debug("Container Invoker Server SocketAddr='"+(serverAddress
>== null ? "Default" : serverAddress)+"'");
> Logger.debug("Container Invoker Optimize='"+optimize+"'");
> }
>
> @@ -567,7 +577,7 @@
>
> // Protected -----------------------------------------------------
> protected void rebind(Context ctx, String name, Object val)
> - throws NamingException
> + throws NamingException
> {
> // Bind val to name in ctx, and make sure that all intermediate
>contexts exist
>
> @@ -610,7 +620,42 @@
> {
> Class ssfClass = loader.loadClass(serverSocketFactoryName);
> serverSocketFactory = (RMIServerSocketFactory)
>ssfClass.newInstance();
> + if( serverAddress != null )
> + {
> + // See if the server socket supports setBindAddress(String)
> + try
> + {
> + Class[] parameterTypes = {String.class};
> + Method m = ssfClass.getMethod("setBindAddress",
>parameterTypes);
> + Object[] args = {serverAddress};
> + m.invoke(serverSocketFactory, args);
> + }
> + catch(NoSuchMethodException e)
> + {
> + Logger.error("Socket factory does not support
setBindAddress(String)");
> + // Go with default address
> + }
> + catch(Exception e)
> + {
> + Logger.error("Failed to setBindAddress="+serverAddress+"
>on socket factory");
> + // Go with default address
> + }
> + }
> }
> + // If a bind address was specified create a DefaultSocketFactory
> + else if( serverAddress != null )
> + {
> + DefaultSocketFactory defaultFactory = new DefaultSocketFactory();
> + serverSocketFactory = defaultFactory;
> + try
> + {
> + defaultFactory.setBindAddress(serverAddress);
> + }
> + catch(UnknownHostException e)
> + {
> + Logger.error("Failed to setBindAddress="+serverAddress+"
>on socket factory, "+e.getMessage());
> + }
> + }
> }
> catch(Exception e)
> {
> @@ -621,4 +666,3 @@
>
> // Inner classes -------------------------------------------------
> }
> -
>
>
>
> No revision
>
>
> No revision
>
>
> 1.1.2.1 +55 -0
>jboss/src/main/org/jboss/ejb/plugins/jrmp/server/Attic/DefaultSocketFactory.java
>
>
>
>
>
>
>
>--__--__--
>
>_______________________________________________
>Jboss-development mailing list
>[EMAIL PROTECTED]
>http://lists.sourceforge.net/lists/listinfo/jboss-development
>
>
>End of Jboss-development Digest
>
Visit iWon.com - the Internet's largest guaranteed cash giveaway! Click
here now for your "Thank You" gift:
http://www.iwon.com/giftcenter/0,2612,,00.html?t_id=20157
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
