Examples of org.hornetq.core.client.impl.LargeMessageControllerImpl.addPacket()

Class org.hornetq.core.client.impl.LargeMessageControllerImpl

Examples of org.hornetq.core.client.impl.LargeMessageControllerImpl.addPacket()

org.hornetq.core.client.impl.LargeMessageControllerImpl.addPacket()
Add a buff to the List, or save it to the OutputStream if set @param packet

   public void testReadPartialData() throws Exception
   {


      final LargeMessageControllerImpl buffer = new LargeMessageControllerImpl(new FakeConsumerInternal(), 10, 10);


      buffer.addPacket(new FakePacket(-1, new byte[] { 0, 1, 2, 3, 4 }, true, true));


      byte bytes[] = new byte[30];
      buffer.readBytes(bytes, 0, 5);


      for (byte i = 0; i < 5; i++)

View Full Code Here

            byte buffer[] = new byte[10240];
            for (int j = 0; j < 10240; j++)
            {
               buffer[j] = getSamplebyte(count++);
            }
            outBuffer.addPacket(new FakePacket(1, buffer, true, false));
         }


         outBuffer.readerIndex(0);


         for (int i = 0; i < 10240 * 10; i++)

View Full Code Here

      treader.setDaemon(true);
      treader.start();


      for (int i = 0; i < 3; i++)
      {
         outBuffer.addPacket(new FakePacket(-1, new byte[1024], true, false));
      }


      outBuffer.setOutputStream(output);


      final CountDownLatch waiting = new CountDownLatch(1);

View Full Code Here

      Assert.assertEquals(3, count.get());
      Assert.assertEquals(1024 * 3, totalBytes.get());


      for (int i = 0; i < 8; i++)
      {
         outBuffer.addPacket(new FakePacket(-1, new byte[1024], true, false));
      }


      Assert.assertEquals(1, waiting.getCount());


      outBuffer.addPacket(new FakePacket(-1, new byte[123], false, false));

View Full Code Here

         outBuffer.addPacket(new FakePacket(-1, new byte[1024], true, false));
      }


      Assert.assertEquals(1, waiting.getCount());


      outBuffer.addPacket(new FakePacket(-1, new byte[123], false, false));


      Assert.assertTrue(done2.await(10, TimeUnit.SECONDS));


      Assert.assertTrue(waiting.await(10, TimeUnit.SECONDS));

View Full Code Here

   public void testErrorOnSetStreaming() throws Exception
   {
      long start = System.currentTimeMillis();
      final LargeMessageControllerImpl outBuffer = new LargeMessageControllerImpl(new FakeConsumerInternal(), 5, 30);


      outBuffer.addPacket(new FakePacket(-1, new byte[] { 0, 1, 2, 3, 4 }, true, false));


      final CountDownLatch latchBytesWritten1 = new CountDownLatch(5);
      final CountDownLatch latchBytesWritten2 = new CountDownLatch(10);


      outBuffer.setOutputStream(new OutputStream()

View Full Code Here

         else
         {
            packet = new FakePacket(1, splitElement, input.available() > 0, false);
         }


         outBuffer.addPacket(packet);
      }


      return outBuffer;


   }

View Full Code Here

   public void testReadPartialData() throws Exception
   {


      final LargeMessageControllerImpl buffer = new LargeMessageControllerImpl(new FakeConsumerInternal(), 10, 10000);


      buffer.addPacket(new FakePacket(-1, new byte[] { 0, 1, 2, 3, 4 }, true, true));


      byte bytes[] = new byte[30];
      buffer.readBytes(bytes, 0, 5);


      for (byte i = 0; i < 5; i++)

View Full Code Here

            byte buffer[] = new byte[10240];
            for (int j = 0; j < 10240; j++)
            {
               buffer[j] = getSamplebyte(count++);
            }
            outBuffer.addPacket(new FakePacket(1, buffer, true, false));
         }


         outBuffer.readerIndex(0);


         for (int i = 0; i < 10240 * 10; i++)

View Full Code Here

      treader.setDaemon(true);
      treader.start();


      for (int i = 0; i < 3; i++)
      {
         outBuffer.addPacket(new FakePacket(-1, new byte[1024], true, false));
      }


      outBuffer.setOutputStream(output);


      final CountDownLatch waiting = new CountDownLatch(1);

View Full Code Here

0 1 2 3

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.