[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/transport/bisocket/ssl/custom ...

[Ron Sigal]

  User: rsigal  
  Date: 06/12/20 04:01:51

  Modified:    src/tests/org/jboss/test/remoting/transport/bisocket/ssl/custom 
                        Tag: remoting_2_x SSLBisocketInvokerClientTest.java
  Log:
  JBREM-650: Added overriding testCallbacks().
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.2   +55 -1     JBossRemoting/src/tests/org/jboss/test/remoting/transport/bisocket/ssl/custom/Attic/SSLBisocketInvokerClientTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: SSLBisocketInvokerClientTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/transport/bisocket/ssl/custom/Attic/SSLBisocketInvokerClientTest.java,v
  retrieving revision 1.1.2.1
  retrieving revision 1.1.2.2
  diff -u -b -r1.1.2.1 -r1.1.2.2
  --- SSLBisocketInvokerClientTest.java	19 Dec 2006 06:19:23 -0000	1.1.2.1
  +++ SSLBisocketInvokerClientTest.java	20 Dec 2006 09:01:51 -0000	1.1.2.2
  @@ -22,19 +22,73 @@
   
   package org.jboss.test.remoting.transport.bisocket.ssl.custom;
   
  +import java.util.HashMap;
  +import java.util.List;
  +
  +import org.apache.log4j.Logger;
  +import org.jboss.remoting.InvokerLocator;
  +import org.jboss.remoting.security.SSLSocketBuilder;
  +import org.jboss.remoting.transport.Connector;
  +import org.jboss.remoting.transport.bisocket.Bisocket;
   import org.jboss.test.remoting.transport.socket.ssl.custom.InvokerClientTest;
   
   
   /**
    * @author <a href="mailto:tom at jboss.com">Tom Elrod</a>
    * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  - * @version $Revision: 1.1.2.1 $
  + * @version $Revision: 1.1.2.2 $
    * <p>
    * Copyright (c) Dec 15, 2006
    * </p>
    */
   public class SSLBisocketInvokerClientTest extends InvokerClientTest
   {
  +   private static Logger log = Logger.getLogger(SSLBisocketInvokerClientTest.class);
  +   
  +   public void testCallbacks()
  +   {
  +      try
  +      {
  +         InvokerLocator locator = new InvokerLocator(getTransport() + "://localhost:" + callbackPort);
  +         HashMap config = new HashMap();
  +         config.put(SSLSocketBuilder.REMOTING_TRUST_STORE_TYPE, "JKS");
  +         String trustStoreFilePath = this.getClass().getResource("../.truststore").getFile();
  +         config.put(SSLSocketBuilder.REMOTING_TRUST_STORE_FILE_PATH, trustStoreFilePath);
  +         config.put(SSLSocketBuilder.REMOTING_TRUST_STORE_PASSWORD, "unit-tests-client");
  +         config.put(Bisocket.IS_CALLBACK_SERVER, "true");
  +         Connector callbackConnector = new Connector(locator.getLocatorURI(), config);
  +         callbackConnector.setServerSocketFactory(createServerSocketFactory());
  +         callbackConnector.create();
  +         callbackConnector.addInvocationHandler("sample", new SampleInvocationHandler());
  +         callbackConnector.start();
  +
  +         CallbackHandler callbackHandler = new CallbackHandler();
  +         String callbackHandleObject = "myCallbackHandleObject";
  +         client.addListener(callbackHandler, locator, callbackHandleObject);
  +         solicitCallback("abc");
  +         
  +         // need to wait for brief moment so server can callback
  +         Thread.sleep(500);
  +         
  +         // remove callback handler from server
  +         client.removeListener(callbackHandler);
  +         
  +         // shut down callback server
  +         callbackConnector.stop();
  +         callbackConnector.destroy();
  +         callbackConnector = null;
  +         
  +         List callbacks = callbackHandler.getCallbacks();
  +         assertEquals(callbacks.size(), 1);
  +//         assertEquals(callbacks.get(0), "abc");
  +      }
  +      catch (Throwable t)
  +      {
  +         log.error(t);
  +         t.printStackTrace();
  +         fail();
  +      }
  +   }
   
      protected String getTransport()
      {