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

               System.out.println("Sending the message.");


               producer.send(message);


               ClientConsumer messageConsumer = session.createConsumer(queueName);
               session.start();


               ClientMessage messageReceived = messageConsumer.receive(1000);
               System.out.println("Received TextMessage:" + messageReceived.getStringProperty(propName));
            } finally {
               if (session != null) {

View Full Code Here

      }


      session.commit();


      ClientConsumer consumer = session.createConsumer("q1", true);
      session.start();


      assertNotNull(consumer.receive(5000));
      consumer.close();


      QueueControl q1Control = ManagementControlHelper.createQueueControl(new SimpleString("q1"),

View Full Code Here


      consumer.close();


      q2Control.moveMessages(null, "q1", false);


      session.start();
      consumer = session.createConsumer("q1");


      for (int i = 0; i < 10; i++)
      {
         ClientMessage msg = consumer.receive(5000);

View Full Code Here

      }


      session.commit();


      ClientConsumer consumer = session.createConsumer("q1", true);
      session.start();


      assertNotNull(consumer.receive(5000));
      consumer.close();


      QueueControl q1Control = ManagementControlHelper.createQueueControl(new SimpleString("q1"),

View Full Code Here

      {
         q2Control.moveMessage(messageIDs[i], "q1");
      }




      session.start();
      consumer = session.createConsumer("q1");


      for (int i = 0; i < NUMBER_OF_MSGS; i++)
      {
         ClientMessage msg = consumer.receive(5000);

View Full Code Here

      
      JMSQueueControl control = createManagementControl(pagedQueue);
      
      assertEquals(100, control.removeMessages("even=true"));
      
      session.start();
      
      ClientConsumer consumer = session.createConsumer(pagedQueue.getAddress());

View Full Code Here


         session.close();


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


         session.start();


         ClientConsumer consumer = session.createConsumer(ADDRESS);


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

View Full Code Here


         locator = createInVMNonHALocator();


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


         session.start();


         consumer = session.createConsumer(ADDRESS);


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

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);
                     assertNotNull(msg);

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);
                     assertNotNull(msg);

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.