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


      ServerLocator locator = createInVMNonHALocator();


      ClientSessionFactory sf = locator.createSessionFactory();


      ClientSession session = sf.createSession(true, true);
      
      ClientProducer prod = session.createProducer(pagedQueue.getAddress());
      
      ClientMessage msg = session.createMessage(true);

View Full Code Here


      ServerLocator locator = createInVMNonHALocator();


      ClientSessionFactory sf = locator.createSessionFactory();


      ClientSession session = sf.createSession(true, true);
      
      ClientProducer prod = session.createProducer(pagedQueue.getAddress());
      for (int i = 0 ; i < 200; i++)
      {
         ClientMessage msg = session.createMessage(true);

View Full Code Here


         ClientSessionFactory sf1 = locator.createSessionFactory(server1tc);


         ClientSession session0 = sf0.createSession(false, true, true);


         ClientSession session1 = sf1.createSession(false, true, true);


         ClientProducer producer0 = session0.createProducer(new SimpleString(testAddress));


         ClientConsumer consumer1 = session1.createConsumer(queueName1);

View Full Code Here

         locator.setBlockOnAcknowledge(true);
         locator.setConsumerWindowSize(1024 * 1024);


         ClientSessionFactory sf = locator.createSessionFactory();


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


         Queue queue = server.createQueue(ADDRESS, ADDRESS, null, true, false);


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

View Full Code Here


         session.commit();


         session.close();


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


         session.start();


         ClientConsumer consumer = session.createConsumer(ADDRESS);

View Full Code Here

         sf.close();
         sf = locator.createSessionFactory();


         locator = createInVMNonHALocator();


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


         session.start();


         consumer = session.createConsumer(ADDRESS);

View Full Code Here

         locator.setBlockOnAcknowledge(true);
         locator.setConsumerWindowSize(1024 * 1024);


         ClientSessionFactory sf = locator.createSessionFactory();


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


         Queue q1 = server.createQueue(ADDRESS, ADDRESS, null, true, false);


         Queue q2 = server.createQueue(ADDRESS, new SimpleString("inactive"), null, true, false);

View Full Code Here

            {
               try
               {
                  ServerLocator sl = createInVMNonHALocator();
                  ClientSessionFactory sf = sl.createSessionFactory();
                  ClientSession sess = sf.createSession(true, true, 0);
                  sess.start();
                  ClientConsumer cons = sess.createConsumer(ADDRESS);
                  for (int i = 0; i < numberOfMessages; i++)
                  {
                     ClientMessage msg = cons.receive(5000);

View Full Code Here

         locator.setBlockOnAcknowledge(true);
         locator.setConsumerWindowSize(1024 * 1024);


         ClientSessionFactory sf = locator.createSessionFactory();


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


         Queue q1 = server.createQueue(ADDRESS, ADDRESS, null, true, false);


         Queue q2 = server.createQueue(ADDRESS, new SimpleString("inactive"), null, true, false);

View Full Code Here

            {
               try
               {
                  ServerLocator sl = createInVMNonHALocator();
                  ClientSessionFactory sf = sl.createSessionFactory();
                  ClientSession sess = sf.createSession(true, true, 0);
                  sess.start();
                  ClientConsumer cons = sess.createConsumer(ADDRESS);
                  for (int i = 0; i < 100; i++)
                  {
                     ClientMessage msg = cons.receive(5000);

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.