Package org.jboss.remoting.transport

Examples of org.jboss.remoting.transport.Connector.stop()

1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
     
      client1.removeListener(callbackHandler);
      client1.disconnect();
      client2.removeListener(callbackHandler);
      client2.disconnect();
      callbackConnector.stop();
   }
  
  
   public void testTwoClientsOneConnectorTwoHandlers() throws Throwable
   {
View Full Code Here
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
      assertEquals(0, ((MicroSocketClientInvoker) clientInvoker2).getNumberOfUsedConnections());
     
      client.removeListener(callbackHandler1);
      client.removeListener(callbackHandler2);
      client.disconnect();
      callbackConnector.stop();
   }
  
  
   public void testTwoClientsTwoConnectorsOneHandler() throws Throwable
   {
View Full Code Here
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
1271
      client1.removeListener(callbackHandler);
      client1.disconnect();
      client2.removeListener(callbackHandler);
      client2.disconnect();
      callbackConnector1.stop();
      callbackConnector2.stop();
   }
  
  
   public void testTwoClientsTwoConnectorsTwoHandlers() throws Throwable
   {
View Full Code Here
1378
1379
1380
1381
1382
1383
1384
1385
1386
1387
1388
     
      client.removeListener(callbackHandler1);
      client.removeListener(callbackHandler2);
      client.disconnect();
      callbackConnector1.stop();
      callbackConnector2.stop();
   }
  
  
   public void testHearbeat() throws Throwable
   {
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
        
         // 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);
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
         log.error("Can not create marshaller loader.", e);
         if(marshallerConnector != null)
         {
            try
            {
               marshallerConnector.stop();
               marshallerConnector.destroy();
            }
            catch(Exception e1)
            {
               log.error("Error cleaning up marshaller loader connector.", e1);
View Full Code Here
256
257
258
259
260
261
262
263
264
265
266
      Thread.sleep(500);
      assertTrue(listener1.visited());
      assertFalse(listener2.visited());
     
      client.disconnect();
      connector.stop();
      log.info(getName() + " PASSES");
   }

  
   public void testServerSideListener() throws Throwable
View Full Code Here
291
292
293
294
295
296
297
298
299
300
301
      Thread.sleep(500);
      assertTrue(listener1.visited());
      assertFalse(listener2.visited());
     
      client.disconnect();
      connector.stop();
      log.info(getName() + " PASSES");
   }
  
  
   public void testCallbackListeners() throws Throwable
View Full Code Here
337
338
339
340
341
342
343
344
345
346
347
      assertEquals(30, i.intValue());
      Thread.sleep(500);
      assertTrue(checkListenersVisited(listener1, listener2, listener3, listener4));
     
      client.disconnect();
      connector.stop();
      log.info(getName() + " PASSES");
   }
  
  
   protected boolean checkListenersVisited(TestListener listener1, TestListener listener2,
View Full Code Here
386
387
388
389
390
391
392
393
394
395
396
      {
         log.info("CAUGHT EXPECTED EXCEPTION");
      }
     
      client.disconnect();
      connector.stop();
      log.info(getName() + " PASSES");
   }
  
  
   public void testExceptionFromServerListener() throws Throwable
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.