Examples of org.hornetq.api.core.client.ClientConsumer.receive()

Class org.hornetq.api.core.client.ClientConsumer

Examples of org.hornetq.api.core.client.ClientConsumer.receive()

org.hornetq.api.core.client.ClientConsumer.receive()
Receives a message from a queue.
This call will block indefinitely until a message is received.
Calling this method on a closed consumer will throw a HornetQException. @return a ClientMessage @throws HornetQException if an exception occurs while waiting to receive a message

      assertNull(cons.receive(500));


      Thread.sleep(5000);


      ClientConsumer cons2 = sess.createConsumer("q2");
      assertNull(cons2.receive(500));


      long timeout = System.currentTimeMillis() + 5000;


      while (System.currentTimeMillis() < timeout && server.getPagingManager().getPageStore(ADDRESS).isPaging())
      {

View Full Code Here

         {
            ClientConsumer cons = session.createConsumer("q" + i);


            for (int j = 0; j < 3; j++)
            {
               ClientMessage msg = cons.receive(5000);


               assertNotNull(msg);


               assertEquals("str-" + j, msg.getStringProperty("id"));

View Full Code Here

         {
            ClientConsumer cons = session.createConsumer("q" + i);


            for (int j = 3; j < 6; j++)
            {
               ClientMessage msg = cons.receive(5000);


               assertNotNull(msg);


               assertEquals("str-" + j, msg.getStringProperty("id"));

View Full Code Here


               msg.acknowledge();
            }


            session.commit();
            assertNull(cons.receive(500));


         }


         session.close();

View Full Code Here


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


         for (int i = 0; i < numberOfMessages; i++)
         {
            message = consumer.receive(5000);
            assertNotNull(message);
            message.acknowledge();


            assertEquals(i, message.getIntProperty("id").intValue());
            if (i % 1000 == 0)

View Full Code Here


                     session.start();


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


                        Assert.assertNotNull(message2);


                        Assert.assertEquals(i, message2.getIntProperty("id").intValue());

View Full Code Here


                  session.start();


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


                     Assert.assertNotNull(message2);


                     Assert.assertEquals(i, message2.getIntProperty("id").intValue());

View Full Code Here


         session.start();


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


            Assert.assertNotNull(message2);


            Assert.assertEquals(i, message2.getIntProperty("id").intValue());

View Full Code Here

            if (i == 5)
            {
               ClientConsumer consumer = session.createConsumer(PagingTest.ADDRESS);
               for (int j = 0; j < numberOfMessages; j++)
               {
                  ClientMessage msg = consumer.receive(PagingTest.RECEIVE_TIMEOUT);
                  msg.acknowledge();
                  Assert.assertNotNull(msg);
               }


               Assert.assertNull(consumer.receiveImmediate());

View Full Code Here


         sessionTransacted.close();


         for (int i = 0; i < 10; i++)
         {
            message = consumer.receive(PagingTest.RECEIVE_TIMEOUT);


            Assert.assertNotNull(message);


            Integer messageID = (Integer)message.getObjectProperty(new SimpleString("id"));

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.