Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
  * JBoss, Home of Professional Open Source
  * Copyright 2005, JBoss Inc., and individual contributors as indicated
  * by the @authors tag. See the copyright.txt in the distribution for a
  * full listing of individual contributors.
  *
  * This is free software; you can redistribute it and/or modify it
  * under the terms of the GNU Lesser General Public License as
  * published by the Free Software Foundation; either version 2.1 of
 * the License, or (at your option) any later version.
 *
 * This software is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this software; if not, write to the Free
 * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
 */
 package org.jboss.remoting.detection.util;
 
 import  org.apache.log4j.Level;
 import  org.jboss.logging.Logger;
A simple utility class that will periodically print out remoting servers running based on detections. Can specify to either use multicast or jndi detection type.

Author(s):
Tom Elrod
Version:
$Revision: 4198 $
 
 public class DetectorUtil
 {
   
multicast *
 
    public static final String TYPE_MULTICAST = "multicast";
   
jndi *
 
    public static final String TYPE_JNDI = "jndi";
   
2410 *
 
    public static final int DEFAULT_PORT = 2410;
   
localhost *
 
    public static final String DEFAULT_HOST = "localhost";
 
    private String contextFactory = "org.jnp.interfaces.NamingContextFactory";
    private String urlPackage = "org.jboss.naming:org.jnp.interfaces";
 
    private String type = ;
    private int port = ;
    private String host = ;
 
    public DetectorUtil()
    {
    }
 
    public DetectorUtil(String type)
    {
       this(type);
    }
 
    public DetectorUtil(String typeint port)
    {
       this(typeport);
    }
 
    public DetectorUtil(String typeint portString host)
    {
       this. = type;
       this. = port;
       this. = host;
    }
 
    public void start()
    {
       try
       {
 
          org.apache.log4j.BasicConfigurator.configure();
          org.apache.log4j.Category.getRoot().setLevel(Level.DEBUG);
         Logger log = Logger.getLogger(getClass());
         SecurityUtility.setSystemProperty("jboss.identity", String.valueOf(System.currentTimeMillis()));
         MBeanServer server = SecurityUtility.createMBeanServer();
         NetworkRegistry registry = NetworkRegistry.getInstance();
         SecurityUtility.registerMBean(serverregistrynew ObjectName("remoting:type=NetworkRegistry"));
        
         InvokerLocator locator = new InvokerLocator("socket://localhost");
         //ClassLoader clsLoader = Thread.currentThread().getContextClassLoader();
         //SocketServerInvoker invokerSvr = new SocketServerInvoker(clsLoader, locator);
         //ObjectName objName = new ObjectName("jboss.remoting:type=SocketServerInvoker");
         //server.registerMBean(invokerSvr, objName);
         //invokerSvr.start();
         Connector connector = new Connector();
         connector.setInvokerLocator(locator.getLocatorURI());
         ObjectName obj = new ObjectName("jboss.remoting:type=Connector,transport=" + locator.getProtocol());
         SecurityUtility.registerMBean(serverconnectorobj);
         //connector.create();
         connector.start();
         Detector detector = null;
         ObjectName objName = null;
         if(.equals())
         {
            MulticastDetector mdet = new MulticastDetector();
            mdet.setPort();
            detector = mdet;
            objName = new ObjectName("remoting:type=Detector,transport=multicast");
         }
         else if(.equals())
         {
            JNDIDetector jdet = new JNDIDetector();
            jdet.setPort();
            jdet.setHost();
            jdet.setContextFactory();
            jdet.setURLPackage();
            detector = jdet;
            objName = new ObjectName("remoting:type=Detector,transport=jndi");
         }
         
         SecurityUtility.registerMBean(serverdetectorobjName);
         detector.start();
         ..println("Starting Detector");
         while(true)
         {
            Thread.currentThread().sleep(3000);
            NetworkInstance[] instances = registry.getServers();
            for(int x = 0; x < instances.lengthx++)
            {
               log.debug(instances[x]);
            }
         }
      }
      catch(Exception ex)
      {
         ..println("Error creating and starting DetectorUtil.");
         ex.printStackTrace();
      }
   }
   public static void main(String[] args)
   {
      DetectorUtil test = null;
      if(args.length == 1)
      {
         String type = args[0];
         test = new DetectorUtil(type);
      }
      else if(args.length == 2)
      {
         String type = args[0];
         int port = Integer.parseInt(args[1]);
         test = new DetectorUtil(typeport);
      }
      else if(args.length == 3)
      {
         String type = args[0];
         int port = Integer.parseInt(args[1]);
         String host = args[2];
         test = new DetectorUtil(typeporthost);
      }
      else
      {
         test = new DetectorUtil();
         ..println("Using default type (" + test.getTransport() +
                            ") and default port (" + test.getPort() + ") and " +
                            "default host (" + test.getHost() + ")" +
                            "\nCan enter type (multicast, jndi), port, and/or host via command line.");
      }
      test.start();
   }
   private String getHost()
   {
      return ;
   }
   private int getPort()
   {
      return ;
   }
   private String getTransport()
   {
      return ;
   }
New to GrepCode? Check out our FAQ X