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

Class org.hornetq.api.core.client.ClientSession

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

org.hornetq.api.core.client.ClientSession.start()
Starts the session. The session must be started before ClientConsumers created by the session can consume messages from the queue. @throws HornetQException if an exception occurs while starting the session


         session = sf.createSession(null, null, false, false, false, false, 0);


         ClientConsumer consumer = session.createConsumer(PagingTest.ADDRESS);


         session.start();
         for (int i = 0; i < numberOfMessages; i++)
         {
            System.out.println("Received " + i);
            if (i == 55)
            {

View Full Code Here


         session = sf.createSession(null, null, false, false, false, false, 0);


         ClientConsumer consumer = session.createConsumer(PagingTest.ADDRESS);


         session.start();
         // 347 = I just picked any odd number, not rounded, to make sure it's not at the beggining of any page
         for (int i = 0; i < 347; i++)
         {
            System.out.println("Received " + i);
            ClientMessage msg = consumer.receive(5000);

View Full Code Here


         session = sf.createSession(null, null, false, false, false, false, 0);


         consumer = session.createConsumer(PagingTest.ADDRESS);


         session.start();
         for (int i = 347; i < numberOfMessages; i++)
         {
            System.out.println("Received " + i);
            ClientMessage msg = consumer.receive(5000);
            assertEquals(i, msg.getIntProperty("id").intValue());

View Full Code Here

            producer.send(message);
         }


         ClientConsumer consumer = session.createConsumer(PagingTest.ADDRESS);


         session.start();


         for (int i = 0; i < 6; i++)
         {
            ClientMessage message2 = consumer.receive(PagingTest.RECEIVE_TIMEOUT);

View Full Code Here


         session.commit();


         consumer = session.createConsumer(PagingTest.ADDRESS);


         session.start();


         for (int i = 0; i < 6; i++)
         {
            ClientMessage message2 = consumer.receive(PagingTest.RECEIVE_TIMEOUT);

View Full Code Here

            }
         }


         ClientConsumer consumer = session.createConsumer(PagingTest.ADDRESS);


         session.start();


         consumer.setMessageHandler(new MyHandler());


         for (int i = 0; i < numberOfMessages; i++)
         {

View Full Code Here


         sf = locator.createSessionFactory();


         session = sf.createSession(null, null, false, true, true, false, 0);


         session.start();


         for (int msg = 0; msg < NUMBER_OF_MESSAGES; msg++)
         {


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

View Full Code Here

         Assert.assertTrue(server.getPostOffice().getPagingManager().getPageStore(PAGED_ADDRESS).isPaging());
         Assert.assertFalse(server.getPostOffice().getPagingManager().getPageStore(NON_PAGED_ADDRESS).isPaging());


         session = sf.createSession(false, true, false);


         session.start();


         ClientConsumer consumerNonPaged = session.createConsumer(NON_PAGED_ADDRESS);
         ClientConsumer consumerPaged = session.createConsumer(PAGED_ADDRESS);


         ClientMessage ackList[] = new ClientMessage[NUMBER_OF_MESSAGES];

View Full Code Here


      ClientSessionFactory csf = locator.createSessionFactory();


      ClientSession session = csf.createSession();


      session.start();


      for (int i = 1; i <= 2; i++)
      {
         ClientConsumer cons = session.createConsumer("q" + i);

View Full Code Here

            }
         }


         session.commit();


         session.start();


         ClientConsumer consumer = session.createConsumer(PagingTest.ADDRESS);


         for (int i = 0; i < numberOfMessages; i++)
         {

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.