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

Class org.hornetq.api.core.HornetQBuffer

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

org.hornetq.api.core.HornetQBuffer.clear()
Sets the {@code readerIndex} and {@code writerIndex} of this buffer to{@code 0}. This method is identical to {@link #setIndex(int,int) setIndex(0, 0)}.
Please note that the behavior of this method is different from that of NIO buffer, which sets the {@code limit} tothe {@code capacity} of the buffer.

      }


      ByteBuffer buffer = fileFactory.newBuffer(message.getEncodeSize() + Page.SIZE_RECORD);


      HornetQBuffer wrap = HornetQBuffers.wrappedBuffer(buffer);
      wrap.clear();


      wrap.writeByte(Page.START_BYTE);
      wrap.writeInt(0);
      int startIndex = wrap.writerIndex();
      message.encode(wrap);

View Full Code Here

   public void write(final PagedMessage message) throws Exception
   {
      ByteBuffer buffer = fileFactory.newBuffer(message.getEncodeSize() + PageImpl.SIZE_RECORD);


      HornetQBuffer wrap = HornetQBuffers.wrappedBuffer(buffer);
      wrap.clear();


      wrap.writeByte(PageImpl.START_BYTE);
      wrap.writeInt(0);
      int startIndex = wrap.writerIndex();
      message.encode(wrap);

View Full Code Here

   public void write(final PagedMessage message) throws Exception
   {
      ByteBuffer buffer = fileFactory.newBuffer(message.getEncodeSize() + PageImpl.SIZE_RECORD);


      HornetQBuffer wrap = HornetQBuffers.wrappedBuffer(buffer);
      wrap.clear();


      wrap.writeByte(PageImpl.START_BYTE);
      wrap.writeInt(0);
      int startIndex = wrap.writerIndex();
      message.encode(wrap);

View Full Code Here

            if (i == 10000)
            {
               start = System.currentTimeMillis();
            }


            buffer.clear();
            buffer.writeUTF(str);
         }


         long spentTime = System.currentTimeMillis() - start;

View Full Code Here

      TypedProperties decodedProps = new TypedProperties();
      decodedProps.decode(buffer);


      TypedPropertiesTest.assertEqualsTypeProperties(props, decodedProps);


      buffer.clear();


      // After removing a property, you should still be able to encode the Property
      props.removeProperty(keyToRemove);
      props.encode(buffer);

View Full Code Here

      if (!str.equals("doo be doo be doo be doo"))
      {
         throw new IllegalStateException("Wrong body!!");
      }


      buffer.clear();


      buffer.writeString("dee be dee be dee be dee");


      return message;
   }

View Full Code Here

   public void write(final PagedMessage message) throws Exception
   {
      ByteBuffer buffer = fileFactory.newBuffer(message.getEncodeSize() + PageImpl.SIZE_RECORD);


      HornetQBuffer wrap = HornetQBuffers.wrappedBuffer(buffer);
      wrap.clear();


      wrap.writeByte(PageImpl.START_BYTE);
      wrap.writeInt(0);
      int startIndex = wrap.writerIndex();
      message.encode(wrap);

View Full Code Here

      }


      ByteBuffer buffer = fileFactory.newBuffer(message.getEncodeSize() + Page.SIZE_RECORD);


      HornetQBuffer wrap = HornetQBuffers.wrappedBuffer(buffer);
      wrap.clear();


      wrap.writeByte(Page.START_BYTE);
      wrap.writeInt(0);
      int startIndex = wrap.writerIndex();
      message.encode(wrap);

View Full Code Here

   {
      checkWrite();


      HornetQBuffer buff = message.getBodyBuffer();


      buff.clear();


      if (text != null)
      {
         this.text = new SimpleString(text);
      }

View Full Code Here

   {
      checkWrite();


      HornetQBuffer buff = message.getBodyBuffer();


      buff.clear();


      if (text != null)
      {
         this.text = new SimpleString(text);
      }

View Full Code Here

0 1 2

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.