Examples of org.hornetq.api.core.HornetQBuffer.resetReaderIndex()

Class org.hornetq.api.core.HornetQBuffer

Examples of org.hornetq.api.core.HornetQBuffer.resetReaderIndex()

org.hornetq.api.core.HornetQBuffer.resetReaderIndex()
Repositions the current {@code readerIndex} to the marked{@code readerIndex} in this buffer. @throws IndexOutOfBoundsException if the current {@code writerIndex} is less than the marked{@code readerIndex}

      for (int i = 0; i < numMessages; i++)
      {
         HornetQBuffer horn1 = buffers.get(i);
         HornetQBuffer horn2 = msg.get(i).getMessage().getBodyBuffer();
         horn1.resetReaderIndex();
         horn2.resetReaderIndex();
         for (int j = 0; j < horn1.writerIndex(); j++)
         {
            Assert.assertEquals(horn1.readByte(), horn2.readByte());
         }
      }

View Full Code Here

      for (int i = 0; i < numMessages; i++)
      {
         HornetQBuffer horn1 = buffers.get(i);
         HornetQBuffer horn2 = msg.get(i).getMessage().getBodyBuffer();
         horn1.resetReaderIndex();
         horn2.resetReaderIndex();
         for (int j = 0; j < horn1.writerIndex(); j++)
         {
            Assert.assertEquals(horn1.readByte(), horn2.readByte());
         }
      }

View Full Code Here

            long sizeBody = newServerMessage.getLongProperty(Message.HDR_LARGE_BODY_SIZE);


            byte[] data = new byte[(int)sizeBody];
            inflater.inflate(data);
            inflater.end();
            qbuff.resetReaderIndex();
            qbuff.resetWriterIndex();
            qbuff.writeBytes(data);
         }


         frame = connection.createStompMessage(newServerMessage, subscription, deliveryCount);

View Full Code Here

      for (int i = 0; i < numMessages; i++)
      {
         HornetQBuffer horn1 = buffers.get(i);
         HornetQBuffer horn2 = msg.get(i).getMessage().getBodyBuffer();
         horn1.resetReaderIndex();
         horn2.resetReaderIndex();
         for (int j = 0; j < horn1.writerIndex(); j++)
         {
            Assert.assertEquals(horn1.readByte(), horn2.readByte());
         }
      }

View Full Code Here

   {
      HornetQBuffer body = message.getBodyBuffer();


      if (body != null)
      {
         body.resetReaderIndex();
      }
   }


   public byte getType()
   {

View Full Code Here


      HornetQBuffer body = message.getBodyBuffer();


      if (body != null)
      {
         body.resetReaderIndex();
      }
   }


   public byte getType()
   {

View Full Code Here

      for (int i = 0; i < numMessages; i++)
      {
         HornetQBuffer horn1 = buffers.get(i);
         HornetQBuffer horn2 = msg.get(i).getMessage().getBodyBuffer();
         horn1.resetReaderIndex();
         horn2.resetReaderIndex();
         for (int j = 0; j < horn1.writerIndex(); j++)
         {
            Assert.assertEquals(horn1.readByte(), horn2.readByte());
         }
      }

View Full Code Here

                        }
                        else
                        {


                           HornetQBuffer buffer = message.getBodyBuffer();
                           buffer.resetReaderIndex();
                           for (long b = 0; b < numberOfBytes; b++)
                           {
                              if (b % (1024l * 1024l) == 0)
                              {
                                 LargeMessageTestBase.log.debug("Read " + b + " bytes");

View Full Code Here

                     Assert.assertEquals(i,
                                         ((Integer)message.getObjectProperty(new SimpleString("counter-message"))).intValue());
                  }


                  HornetQBuffer buffer = message.getBodyBuffer();
                  buffer.resetReaderIndex();


                  if (useStreamOnConsume)
                  {
                     final AtomicLong bytesRead = new AtomicLong(0);
                     message.saveToOutputStream(new OutputStream()

View Full Code Here

      for (int i = 0; i < numMessages; i++)
      {
         HornetQBuffer horn1 = buffers.get(i);
         HornetQBuffer horn2 = msg.get(i).getMessage(null).getBodyBuffer();
         horn1.resetReaderIndex();
         horn2.resetReaderIndex();
         for (int j = 0; j < horn1.writerIndex(); j++)
         {
            Assert.assertEquals(horn1.readByte(), horn2.readByte());
         }
      }

View Full Code Here

0 1 2 3 4

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.