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

Class org.jboss.remoting.transport.Connector

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

org.jboss.remoting.transport.Connector.stop()
Stops the connector. Will also stop and destroy server invoker (transport) @jmx.managed-operation description = "Stop tears down the ServerInvoker we are wrapping."impact = "ACTION"

         
         client.disconnect();
         assertTrue(MultiplexServerInvoker.getSocketGroupMap().containsKey("id"));
         assertTrue(MultiplexServerInvoker.getAddressPairMap().containsKey(addressPair));
         
         callbackConnector.stop();
         assertFalse(MultiplexServerInvoker.getSocketGroupMap().containsKey("id"));
         assertFalse(MultiplexServerInvoker.getAddressPairMap().containsKey(addressPair));
         
         log.info("testClientStartsClient2WithIdServer2WithoutIdServerCloses() PASSES");
         OKCounter++;

View Full Code Here

            {
               Iterator it = connectors.iterator();
               while (it.hasNext())
               {
                  Connector callbackConnector = (Connector) it.next();
                  callbackConnector.stop();
                  callbackConnector.destroy();
               }
            }
         }
         else

View Full Code Here

         // Give virtual MultiplexServerInvoker time to time out, then check that it shut down.
         Thread.sleep(5000);
         virtualInvoker = masterInvoker.getServerInvoker(bindAddress);
         assertTrue(virtualInvoker == null);
         
         connector.stop();
      }
      catch (Exception e)
      {
         log.error(e);
         e.printStackTrace();

View Full Code Here

            Client client1 = new Client(new InvokerLocator(locatorString1), "test");
            client1.connect();
            String results = (String) client1.invoke("");
            assert "foo".equals(results) : "Results were " + results;


            c1.stop();
            c1.destroy();
            c1.create();


            c1.addInvocationHandler("test", this);
            c1.start();

View Full Code Here

            c1.start();


            results = (String) client1.invoke("");
            assert "foo".equals(results) : "Results were " + results;
        } finally {
            c1.stop();
            c1.destroy();
        }
    }


    @Test(groups = "comm.client")

View Full Code Here

            JBossRemotingRemoteCommunicator client1 = new JBossRemotingRemoteCommunicator(locatorString1);
            client1.connect();
            CommandResponse results = client1.send(new IdentifyCommand());
            assert "foo".equals(results.getResults()) : "Results were " + results;


            c1.stop();
            c1.destroy();


            Thread.sleep(5000); // I have no idea if this will matter, but maybe this avoids the address-already-in-use error we periodically get


            c1.create();

View Full Code Here

            c1.start();


            results = client1.send(new IdentifyCommand());
            assert "foo".equals(results.getResults()) : "Results were " + results;
        } finally {
            c1.stop();
            c1.destroy();
        }
    }


    // ServerInvocationHandler methods

View Full Code Here

      usedPooled = (Long) field.get(clientInvoker);
      assertEquals(0, usedPooled.intValue());
      
      client.removeListener(callbackHandler);
      client.disconnect();
      callbackConnector.stop();
   }
   
   
   public void testOneClientOneConnectorTwoHandlers() throws Throwable
   {

View Full Code Here

      assertEquals(0, usedPooled2.intValue());
      
      client.removeListener(callbackHandler1);
      client.removeListener(callbackHandler2);
      client.disconnect();
      callbackConnector.stop();
   }
   
   
   public void testOneClientTwoConnectorsOneHandler() throws Throwable
   {

View Full Code Here

      assertEquals(0, usedPooled2.intValue());
      
      client.removeListener(callbackHandler);
      client.disconnect();
      callbackConnector1.stop();
      callbackConnector2.stop();
   }
   
  
   public void testOneClientTwoConnectorsTwoHandlers() throws Throwable
   {

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.