Examples of org.jboss.remoting.Client.connect()

org.jboss.remoting.Client.connect()
Will cause the underlying transport to make connection to the target server. This is important for any stateful transports, like socket or multiplex. This is also when a client lease with the server is started.

      
      for (int i = 0; i < 500; i++)
      {
         Client cl = new Client(serverLocator2);
         
         cl.connect();
         
         for (int j = 0; j < 100; j++)
         {
            cl.invoke("pickled onions");
         }

View Full Code Here

      
      try
      {
         client = new Client(new InvokerLocator(serverLocatorURI), configuration);
         client.setSubsystem(ServerPeer.REMOTING_JMS_SUBSYSTEM);
         client.connect();
      }
      catch (Exception e)
      {
         throw new MessagingNetworkFailureException("Failed to connect client", e);
      }

View Full Code Here

         try
         {
            for (int i = 0; i < 5000; i++)
            {
               Client cl = new Client(locator);
               cl.connect();
               cl.invoke("aardvark");
               cl.disconnect();
            }
            synchronized (o)
            {

View Full Code Here

      {
         subsystemService = RemotingTestSubsystemService.deployService();


         client = new Client(serverLocator, RemotingTestSubsystemService.SUBSYSTEM_LABEL);


         client.connect();


         client.invokeOneway("blip");


         // make sure invocation reached the target subsystem

View Full Code Here

      {
         subsystemService = RemotingTestSubsystemService.deployService();


         client = new Client(serverLocator, RemotingTestSubsystemService.SUBSYSTEM_LABEL);


         client.connect();


         // send a ton of invocations
         int COUNT = 200;


         for(int i = 0; i < COUNT; i++)

View Full Code Here


         client = new Client(serverLocator, RemotingTestSubsystemService.SUBSYSTEM_LABEL);


         callbackHandler = new SimpleCallbackHandler();


         client.connect();


         client.addListener(callbackHandler, null, null, true);


         client.invoke(new OnewayCallbackTrigger("blop"));

View Full Code Here

         fail("This test should be run in a remote configuration!");
      }


      Client client = new Client(serverLocator);


      client.connect();


      SimpleConnectionListener connListener = new SimpleConnectionListener();
      client.addConnectionListener(connListener, 50);


      assertEquals(50, client.getPingPeriod());

View Full Code Here


      try
      {
         client = new Client(serverLocator, RemotingTestSubsystemService.SUBSYSTEM_LABEL);


         client.connect();


         SimpleConnectionListener connListener = new SimpleConnectionListener();
         client.addConnectionListener(connListener, 3333);


         log.info("connection listener added, pinging will start in 3.3 secs");

View Full Code Here

      {
         // create a "business" client


         client = new Client(serverLocator, RemotingTestSubsystemService.SUBSYSTEM_LABEL);


         client.connect();


         final Client clientCopy = client;


         // send a "long running" invocation first on a separate thread, so we can setup the
         // connection validator at the same time

View Full Code Here

         fail("This test should be run in a remote configuration!");
      }


      Client client = new Client(serverLocator, RemotingTestSubsystemService.SUBSYSTEM_LABEL);


      client.connect();


      client.invoke("blah");


      assertEquals("blah", RemotingTestSubsystemService.
         getNextInvocationFromServer(subsystemService, 2000).getParameter());

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.