Examples of org.hornetq.api.core.client.ClientSessionFactory.createSession()

Class org.hornetq.api.core.client.ClientSessionFactory

Examples of org.hornetq.api.core.client.ClientSessionFactory.createSession()

org.hornetq.api.core.client.ClientSessionFactory.createSession()
Creates a non-transacted session. Message sends and acknowledgements are automatically committed by the session. This does not mean that messages are automatically acknowledged, only that when messages are acknowledged, the session will automatically commit the transaction containing the acknowledgements. @return a non-transacted ClientSession @throws HornetQException if an exception occurs while creating the session

         locator.setBlockOnNonDurableSend(true);
         locator.setBlockOnDurableSend(true);
         locator.setBlockOnAcknowledge(true);


         ClientSessionFactory sf = locator.createSessionFactory();
         ClientSession session = sf.createSession(null, null, false, false, false, false, 0);


         session.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true);


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

View Full Code Here


         locator = createInVMNonHALocator();


         sf = locator.createSessionFactory();


         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

View Full Code Here


         locator = createInVMNonHALocator();


         sf = locator.createSessionFactory();


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


         consumer = session.createConsumer(PagingTest.ADDRESS);


         session.start();
         for (int i = 347; i < numberOfMessages; i++)

View Full Code Here

         locator.setBlockOnNonDurableSend(true);
         locator.setBlockOnDurableSend(true);
         locator.setBlockOnAcknowledge(true);


         ClientSessionFactory sf = locator.createSessionFactory();
         ClientSession session = sf.createSession(null, null, false, true, true, false, 0);


         session.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true);


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

View Full Code Here


         Assert.assertNull(consumer.receiveImmediate());


         session.close();


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


         producer = session.createProducer(PagingTest.ADDRESS);


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

View Full Code Here

      {


         locator.setAckBatchSize(0);


         ClientSessionFactory sf = locator.createSessionFactory();
         ClientSession session = sf.createSession();


         session.createQueue(PagingTest.ADDRESS, PagingTest.ADDRESS, null, true);


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

View Full Code Here

         locator.setBlockOnNonDurableSend(true);
         locator.setBlockOnDurableSend(true);
         locator.setBlockOnAcknowledge(true);


         ClientSessionFactory sf = locator.createSessionFactory();
         ClientSession session = sf.createSession(null, null, false, !transacted, true, false, 0);


         for (int i = 0; i < NUMBER_OF_BINDINGS; i++)
         {
            session.createQueue(PagingTest.ADDRESS, new SimpleString("someQueue" + i), null, true);
         }

View Full Code Here

                               new HashMap<String, AddressSettings>());
         server.start();


         sf = locator.createSessionFactory();


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


         session.start();


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

View Full Code Here

      {
         server.start();


         ClientSessionFactory sf = locator.createSessionFactory();


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


         session.createQueue(PAGED_ADDRESS, PAGED_ADDRESS, true);


         session.createQueue(NON_PAGED_ADDRESS, NON_PAGED_ADDRESS, true);

View Full Code Here

         session.close();


         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);

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.