Examples of ConnectionListener

com.ettrema.httpclient.ConnectionListener
@author mcevoyb
com.ponysdk.core.socket.ConnectionListener
com.rabbitmq.messagepatterns.unicast.ConnectionListener
com.sun.sgs.io.ConnectionListener
Receives asynchronous notification of events from an associated {@link Connection}. The {@code connected} method is invoked when theconnection is established, either actively from a {@link Connector} orpassively by an {@link Acceptor}. The {@code bytesReceived} method isinvoked when data arrives on the connection. The {@code exceptionThrown}method is invoked to forward asynchronous network exceptions. The {@code disconnected} method is invoked when the connection has beenclosed, or if the connection could not be initiated at all (e.g., when a connector fails to connect).
The IO framework ensures that only one notification is processed at a time for each instance of {@code Connection}. Thus, a {@code ConnectionListener} does not need to take special steps to ensurethread safety so long as it does not access resources shared among the listeners of other connections.
de.fhkn.in.uce.holepunching.core.ConnectionListener
Class to listen for incoming connections. Listener can be stopped and restarted. To get a established connection you have to register for a specific remote endpoint. @author Daniel Maier
hermes.ConnectionListener
@author colincrist@hermesjms.com @version $Id: ConnectionListener.java,v 1.1 2006/10/29 07:37:22 colincrist Exp $
info.walnutstreet.vs.ps03.appserver.listener.ConnectionListener
@author Christoph Gostner @author Romedius Weiss @version 0.1
jetbrains.communicator.jabber.ConnectionListener
@author Kir
net.sf.jftp.net.ConnectionListener
Classes that implement this interface are notified about various events that may happen. Make sure to use myftpconnection.addConnectionListener(this) in the class to get it working.
net.sourceforge.squirrel_sql.plugins.hibernate.ConnectionListener
org.apache.qpid.jms.ConnectionListener
org.jboss.jca.core.connectionmanager.listener.ConnectionListener
Connection listener. @author Gurkan Erdogdu @author Adrian Brock @author Weston Price @author Jesper Pedersen
org.jboss.remoting.ConnectionListener
Listener that can be registered with the Client to receive a callback if the target server for said Client is determined to be unreachable at any point.
Can also be registered with Connector to be notified when client disconnects (but only when leasing is turned on). @author Tom Elrod
org.jboss.resource.connectionmanager.ConnectionListener
A jboss connection listener @author Adrian Brock @author Weston Price @version $Revision: 71554 $
org.jivesoftware.smack.ConnectionListener
Interface that allows for implementing classes to listen for connection closing and reconnection events. Listeners are registered with Connection objects. @see Connection#addConnectionListener @see Connection#removeConnectionListener @author Matt Tucker
org.mule.tck.listener.ConnectionListener
Listener for connection notifications.
org.springframework.amqp.rabbit.connection.ConnectionListener
@author Dave Syer
se.bitcraze.crazyflie.ConnectionListener
Interface for receiving notifications about the connection status of a {@link CrtpDriver}.
weka.gui.sql.event.ConnectionListener
A listener for connect/disconnect events. @author FracPete (fracpete at waikato dot ac dot nz) @version $Revision: 1.1 $

Examples of org.jboss.remoting.ConnectionListener

      assertEquals("abc", client.invoke("abc"));
      
      // Add connection listener.
      Map metadata = new HashMap();
      metadata.put("ReuseAddress", "false");
      ConnectionListener listener = new TestConnectionListener();
      client.addConnectionListener(listener, metadata);
      
      // Test pingPeriod.
      Field field = Client.class.getDeclaredField("connectionValidator");
      field.setAccessible(true);

View Full Code Here

Examples of org.jboss.remoting.ConnectionListener

   {
      Client client = new Client(new InvokerLocator(ClientPingCountTestServer.locatorURI));


      client.connect();


      client.addConnectionListener(new ConnectionListener()
      {
         public void handleConnectionException(Throwable throwable, Client client) {}
      });


      assertEquals(ConnectionValidator.DEFAULT_PING_PERIOD, client.getPingPeriod());

View Full Code Here

Examples of org.jboss.remoting.ConnectionListener

   {
      Client client = new Client(new InvokerLocator(ClientPingCountTestServer.locatorURI));


      client.connect();


      client.addConnectionListener(new ConnectionListener()
      {
         public void handleConnectionException(Throwable throwable, Client client) {}
      }, 7865);


      assertEquals(7865, client.getPingPeriod());

View Full Code Here

Examples of org.jboss.resource.connectionmanager.ConnectionListener

      log.info("------------------------");
      log.info("testGetManagedConnection");
      log.info("------------------------");




      ConnectionListener cl = null;
      try
      {
         assertNotNull(tm);
         tm.begin();


         assertEquals(0, cm.getPoolingStrategy().getInUseConnectionCount());


         cl = cm.getManagedConnection(subject, cri);


         assertEquals(1, cm.getPoolingStrategy().getInUseConnectionCount());
         
         assertNotNull(cl);
         cl.enlist();
         
         assertNotNull(tm);
         tm.commit();
         
         cl.delist();
         cm.returnManagedConnection(cl, false);
         cl = null;


         assertEquals(0, cm.getPoolingStrategy().getInUseConnectionCount());
      }

View Full Code Here

Examples of org.jboss.resource.connectionmanager.ConnectionListener

      log.info("-------------------------------");
      log.info("testGetManagedConnectionTimeout");
      log.info("-------------------------------");




      ConnectionListener cl = null;
      try
      {
         assertNotNull(tm);
         tm.setTransactionTimeout(2);
         tm.begin();


         assertEquals(0, cm.getPoolingStrategy().getInUseConnectionCount());


         cl = cm.getManagedConnection(subject, cri);


         assertEquals(1, cm.getPoolingStrategy().getInUseConnectionCount());
         
         assertNotNull(cl);
         cl.enlist();
         
         Thread.sleep(2500L);


         cl.delist();
         cm.returnManagedConnection(cl, false);


         cl = null;


         assertEquals(0, cm.getPoolingStrategy().getInUseConnectionCount());

View Full Code Here

Examples of org.jboss.resource.connectionmanager.ConnectionListener

      log.info("---------------------------------");


      // track-by-tx = true
      cm.setTrackConnectionByTx(true);


      ConnectionListener cl = null;
      try
      {
         assertNotNull(tm);
         tm.begin();


         assertEquals(0, cm.getPoolingStrategy().getInUseConnectionCount());


         cl = cm.getManagedConnection(subject, cri);


         assertEquals(1, cm.getPoolingStrategy().getInUseConnectionCount());


         assertNotNull(cl);
         cl.enlist();
         
         assertNotNull(tm);
         tm.commit();
         
         assertEquals(0, cm.getPoolingStrategy().getInUseConnectionCount());

View Full Code Here

Examples of org.jboss.resource.connectionmanager.ConnectionListener

      log.info("----------------------------------------");


      // track-by-tx = true
      cm.setTrackConnectionByTx(true);


      ConnectionListener cl = null;
      try
      {
         assertNotNull(tm);
         tm.setTransactionTimeout(2);
         tm.begin();


         assertEquals(0, cm.getPoolingStrategy().getInUseConnectionCount());


         cl = cm.getManagedConnection(subject, cri);


         assertEquals(1, cm.getPoolingStrategy().getInUseConnectionCount());


         assertNotNull(cl);
         cl.enlist();


         Thread.sleep(2500L);


         assertEquals(0, cm.getPoolingStrategy().getInUseConnectionCount());

View Full Code Here

Examples of org.jboss.resource.connectionmanager.ConnectionListener

         ManagedConnectionPool ps = cm.getPoolingStrategy();


         assertTrue("0: Initial check", ps.getConnectionCount() == 0);


         // Get a connection
         ConnectionListener cl = cm.getManagedConnection(null, null);
         assertTrue("1: Got a null connection!", cl.getManagedConnection() != null);
         assertTrue("1: One connection", ps.getConnectionCount() == 1);


         // Get another connection
         ConnectionListener cl2 = cm.getManagedConnection(null, null);
         assertTrue("2: Got a null connection!", cl2.getManagedConnection() != null);
         assertTrue("2: Two connections", ps.getConnectionCount() == 2);


         // Return first
         cm.returnManagedConnection(cl, true);
         assertTrue("3: One connection", ps.getConnectionCount() == 1);

View Full Code Here

Examples of org.jboss.resource.connectionmanager.ConnectionListener

                  long getConnection = 0;
                  long returnConnection = 0;
                  long heldConnection = 0;
                  for (int j = 0; j < reps; j++)
                  {
                     ConnectionListener cl = null;
                     try
                     {
                        if (tm == null)
                           throw new SystemException("TM is null");


                        tm.begin();


                        long startGetConnection = System.currentTimeMillis();
                        cl = cm.getManagedConnection(subject, cri);
                        cl.enlist();
                        long endGetConnection = System.currentTimeMillis();


                        TxConnectionManagerStressTestCase.this.connectionCount.incrementAndGet();


                        Thread.sleep(sleepTime);


                        if (tm == null)
                           throw new SystemException("TM is null");


                        tm.commit();


                        long startReturnConnection = System.currentTimeMillis();
                        if (!trackByTx)
                        {
                           cl.delist();
                           cm.returnManagedConnection(cl, false);
                        }
                        cl = null;
                        long endReturnConnection = System.currentTimeMillis();

View Full Code Here

Examples of org.jboss.resource.connectionmanager.ConnectionListener

      {
         id = startedThreadCount.getAndIncrement();


         for (int j = 0; j < reps; j++)
         {
            ConnectionListener cl = null;
            try
            {
               assertNotNull(tm);


               tm.setTransactionTimeout(2);
               tm.begin();
               Transaction tx = tm.getTransaction();
               tx.registerSynchronization(this);


               cl = cm.getManagedConnection(subject, cri);
               cl.enlist();


               latch.await(20, TimeUnit.SECONDS);


               assertNotNull(tm);


               tx = tm.getTransaction();
               if (tx != null && TxUtils.isActive(tx))
                  failed = true;


               if (!trackByTx)
               {
                  cl.delist();
                  cm.returnManagedConnection(cl, false);
               }
               cl = null;


             }

View Full Code Here

0 1 2 3 4 5 6

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.