List of addFailureListener() Examples

Examples of addFailureListener()

org.hornetq.api.core.client.ClientSession.addFailureListener()
Adds a FailureListener to the session which is notified if a failure occurs on the session. @param listener the listener to add
org.hornetq.core.client.impl.ClientSessionFactoryInternal.addFailureListener()
org.hornetq.core.client.impl.ClientSessionInternal.addFailureListener()
org.hornetq.spi.core.protocol.RemotingConnection.addFailureListener()
add a failure listener.
The listener will be called in the event of connection failure. @param listener the listener

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()

         }
      }


      ClientSession session = sendAndConsume(sf, true);


      session.addFailureListener(new MyListener());


      backupServer.stop();


      liveServer.crash();

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()


         ClientSession session = sf.createSession(true, true, 0);


         MyListener listener = new MyListener();


         session.addFailureListener(listener);


         this.listener = listener;


         ClientProducer producer = session.createProducer(FailoverTestBase.ADDRESS);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()


            final int numMessages = 1000;


            session = sf.createSession(false, false);


            session.addFailureListener(listener);


            do
            {
               try
               {

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()

         }
      }


      MyFailureListener listener = new MyFailureListener();


      session2.addFailureListener(listener);


      session.createQueue(ReattachTest.ADDRESS, ReattachTest.ADDRESS, null, false);


      ClientProducer producer = session.createProducer(ReattachTest.ADDRESS);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()

            {
            }


         }


         session.addFailureListener(new MyListener());


         ClientProducer prod = session.createProducer(PagingFailoverTest.ADDRESS);


         final int TOTAL_MESSAGES = 2000;

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()

      {
         server.start();
         ClientSessionFactory cf = createInVMFactory();
         ClientSession clientSession = cf.createSession(false, true, true);
         final CountDownLatch latch = new CountDownLatch(1);
         clientSession.addFailureListener(new SessionFailureListener()
         {
            public void connectionFailed(final HornetQException me)
            {
               latch.countDown();
            }

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()

            {
            }
         }


         MyFailureListener listener = new MyFailureListener();
         clientSession.addFailureListener(listener);


         Assert.assertTrue(clientSession.removeFailureListener(listener));
         clientSession.close();
         server.stop();
         Assert.assertFalse(listener.called);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()

         {
            latch.countDown();
         }
      }


      session.addFailureListener(new MyListener());


      ClientProducer producer = session.createProducer(FailoverTestBase.ADDRESS);


      final int numMessages = 100;

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()

         {
            latch.countDown();
         }
      }


      session.addFailureListener(new MyListener());


      // create a consumer and start the session before failover
      ClientConsumer consumer = session.createConsumer(FailoverTestBase.ADDRESS);


      session.start();

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.addFailureListener()

         {
            latch.countDown();
         }
      }


      session1.addFailureListener(new MyListener());


      ClientProducer producer = session1.createProducer(FailoverTestBase.ADDRESS);


      final int numMessages = 100;

View Full Code Here

0 1 2 3 4 5

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.