Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.jboss.remoting.samples.transporter.custom.server;
  
 

Author(s):
Tom Elrod
 
 public class HTTPServer
 {
    private TransporterServer server = null;
 
    public void start() throws Exception
    {
       initTransporterServices();
 
       Element xmlConfig = getXmlConfig();
 
        = TransporterServer.createTransporterServer(xmlConfignew CustomerProcessorImpl(),
                                                          CustomerProcessor.class.getName(), true);
    }
 
    {
 
       String transport = "http";
       String host = "localhost";
       int port = 5600;
 
       StringBuffer buf = new StringBuffer();
       buf.append("<?xml version=\"1.0\"?>\n");
       buf.append("<config>");
       buf.append("<invoker transport=\"" + transport + "\">");
       buf.append("<attribute name=\"serverBindAddress\">" + host + "</attribute>");
       buf.append("<attribute name=\"serverBindPort\">" + port + "</attribute>");
       buf.append("</invoker>");
       buf.append("</config>");
       Document xml = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(new ByteArrayInputStream(buf.toString().getBytes()));
       return xml.getDocumentElement();
 
    }
 
    public void stop()
    {
       if ( != null)
       {
          .stop();
       }
    }
 
    private void initTransporterServices() throws Exception
    {
       // create MBeanServer
       MBeanServer mbeanServer = MBeanServerFactory.createMBeanServer();
 
       NetworkRegistry registry = NetworkRegistry.getInstance();
 
       String host = InetAddress.getLocalHost().getHostAddress();
       JNDIDetector jndiDetector = new JNDIDetector();
       jndiDetector.setPort(.);
       jndiDetector.setHost(host);
       jndiDetector.setContextFactory("org.jnp.interfaces.NamingContextFactory");
       jndiDetector.setURLPackage("org.jboss.naming:org.jnp.interfaces");
 
 
       InternalTransporterServices transporterService = InternalTransporterServices.getInstance();
 
       transporterService.setup(mbeanServer,
                                jndiDetectornew ObjectName("remoting:type=Detector,transport=jndi"),
                                registrynew ObjectName("remoting:type=NetworkRegistry"),
                                truetrue);
 
       //TODO: -TME Have to start the detector after setup() call?
       jndiDetector.start();
 
    }
 
 
    public static void main(String[] args)
    {
       HTTPServer server = new HTTPServer();
       try
       {
         server.start();
         Thread.currentThread().sleep(60000);
      }
      catch (Exception e)
      {
         e.printStackTrace();
      }
      finally
      {
         server.stop();
      }
   }
New to GrepCode? Check out our FAQ X