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

                  {
                     ClientSession session = sf2.createSession(null, null, false, true, true, false, 0);


                     ClientConsumer consumer = session.createConsumer(addressToSubscribe);


                     session.start();


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

View Full Code Here

               {
                  ClientSession session = sf2.createSession(null, null, false, true, true, false, 0);


                  ClientConsumer consumer = session.createConsumer(PagingTest.ADDRESS + "-1");


                  session.start();


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

View Full Code Here


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


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


         session.start();


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

View Full Code Here

            producer.send(message);
         }


         Assert.assertTrue(server.getPostOffice().getPagingManager().getPageStore(PagingTest.ADDRESS).isPaging());


         session.start();


         ClientSession sessionTransacted = sf.createSession(null, null, false, false, false, false, 0);


         ClientProducer producerTransacted = sessionTransacted.createProducer(PagingTest.ADDRESS);

View Full Code Here

            producer.send(message);
         }


         Assert.assertTrue(server.getPostOffice().getPagingManager().getPageStore(PagingTest.ADDRESS).isPaging());


         session.start();


         for (int i = 1; i < 10; i++)
         {
            message = session.createMessage(true);
            message.getBodyBuffer().writeBytes(body);

View Full Code Here

         ClientSession sessionNonTX = sf.createSession(true, true, 0);
         sessionNonTX.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true);


         ClientProducer producerNonTransacted = sessionNonTX.createProducer(PagingTest.ADDRESS);


         sessionNonTX.start();


         for (int i = 0; i < 50; i++)
         {
            System.out.println("Sending " + i);
            ClientMessage message = sessionNonTX.createMessage(true);

View Full Code Here

               }
            }
         };


         ClientSession session = sf.createSession(true, true, 0);
         session.start();
         session.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true);


         producerThread.start();


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

View Full Code Here

               }
            }
         };


         ClientSession session = sf.createSession(true, true, 0);
         session.start();
         session.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true);


         producerThread.start();


         assertTrue(ready.await(10, TimeUnit.SECONDS));

View Full Code Here

         Assert.assertTrue(server.getPostOffice().getPagingManager().getPageStore(PAGED_ADDRESS_A).isPaging());
         Assert.assertTrue(server.getPostOffice().getPagingManager().getPageStore(PAGED_ADDRESS_B).isPaging());


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


         session.start();


         ClientConsumer consumerA = session.createConsumer(PAGED_ADDRESS_A);


         ClientConsumer consumerB = session.createConsumer(PAGED_ADDRESS_B);

View Full Code Here

            {
               ClientSession sessionConsumer = null;
               try
               {
                  sessionConsumer = sf.createSession(false, false);
                  sessionConsumer.start();


                  ClientConsumer cons = sessionConsumer.createConsumer(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.