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.
 */
 
 /*
  * Created on Oct 4, 2005
  */
 package org.jboss.remoting.samples.multiplex.invoker;
 /*
  * JBoss, the OpenSource J2EE webOS
  *
  * Distributable under LGPL license.
  * See terms of license at gnu.org.
  */
 
 import java.util.Map;
 

Author(s):
Ron Sigal
 
 public class Client2Server1
 {
    private Client client;
    private SampleCallbackHandler handler;
    private Connector connector;
    private InvokerLocator locator;


   
This will create the Client.
 
    public void init()
    {
       try
       {
          String locatorURI = "multiplex://localhost:9090";
          InvokerLocator locator = new InvokerLocator(locatorURI);
          Map configuration = new HashMap();
          configuration.put(."localhost");
          configuration.put(."8080");
          configuration.put(."client2server2");
           = new Client(locator"sample"configuration);
          .connect();
          ..println("Connected client to server at: " + .getInvoker().getLocator().getLocatorURI());
       }
       catch(Exception e)
       {
          e.printStackTrace();
       }
    }

  
   
This will be used to create callback server

Parameters:
port
Returns:
Throws:
java.lang.Exception
 
    private InvokerLocator initServer() throws Exception
    {
       String locatorURI = "multiplex://localhost:8080";
       InvokerLocator locator = new InvokerLocator(locatorURI);
       Map configuration = new HashMap();
       configuration.put(."client2server2");
        = new Connector(locator.getLocatorURI(), configuration);
       .create();
       .start();
       ..println("Started callback server at:    " + .getInvokerLocator());
       return .getLocator();
    }
   public void setUp() throws Exception
   {
      init();
       = initServer();
   }
   public void tearDown() throws Throwable
   {
      while (!.)
         Thread.sleep(1000);
      
      
      if( != null)
      {
         .stop();
         .destroy();
          = null;
      }
       = null;
      if( != null)
      {
         .disconnect();
          = null;
      }
   }
   public void makeClientCall() throws Throwable
   {
       = new SampleCallbackHandler();
      // Need to add callback listener to get callback
      // make invocation
      Object answer = .invoke(new Integer(17));
      
      ..println("invocation returns: " + ((Integeranswer).intValue());
   }
   public static void main(String[] args)
   {
      Client2Server1 test = new Client2Server1();
      
      try
      {
         test.setUp();
         test.makeClientCall();
         test.tearDown();
      }
      catch(Throwable throwable)
      {
         throwable.printStackTrace();
      }
   }
   
   public static class SampleCallbackHandler implements InvokerCallbackHandler
   {
      int callbackCounter;
      boolean gotCallbacks;
      
      public void handleCallback(Callback callbackthrows HandleCallbackException
      {
         Object ret = callback.getCallbackObject();
         ..println("callback value: " + ret);
         if (++ == 2)
             = true;
      }
      
      public boolean gotCallbacks()
      {
         return ;
      }
   }
New to GrepCode? Check out our FAQ X