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

Class org.hornetq.api.core.HornetQBuffer

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

org.hornetq.api.core.HornetQBuffer.toByteBuffer()
Converts this buffer's readable bytes into a NIO buffer. The returned buffer might or might not share the content with this buffer, while they have separate indexes and marks. This method is identical to {@code buf.toByteBuffer(buf.readerIndex(), buf.readableBytes())}. This method does not modify {@code readerIndex} or {@code writerIndex} ofthis buffer.


               HornetQBuffer bodyBuffer = HornetQBuffers.fixedBuffer(localChunkLen);


               context.encode(bodyBuffer, localChunkLen);


               byte[] body = bodyBuffer.toByteBuffer().array();


               int packetSize = callback.sendLargeMessageContinuation(id,
                                                                      body,
                                                                      positionPendingLargeMessage + localChunkLen < sizePendingLargeMessage,
                                                                      false);

View Full Code Here


            pos += chunkLength;


            lastChunk = pos >= bodySize;


            final SessionSendContinuationMessage chunk = new SessionSendContinuationMessage(bodyBuffer.toByteBuffer()
                                                                                                      .array(),
                                                                                            !lastChunk,
                                                                                            lastChunk && sendBlocking);


            if (sendBlocking && lastChunk)

View Full Code Here

      for (TransportConfiguration tcConfig : connectors)
      {
         tcConfig.encode(buff);
      }


      byte[] data = buff.toByteBuffer().array();


      endpoint.broadcast(data);
   }


   public void run()

View Full Code Here

            pos += chunkLength;


            lastChunk = pos >= bodySize;


            final SessionSendContinuationMessage chunk = new SessionSendContinuationMessage(msgI, 
                                                                                            bodyBuffer.toByteBuffer()
                                                                                                      .array(),
                                                                                            !lastChunk,
                                                                                            lastChunk && sendBlocking);


            if (sendBlocking && lastChunk)

View Full Code Here

      for (TransportConfiguration tcConfig : connectors)
      {
         tcConfig.encode(buff);
      }


      byte[] data = buff.toByteBuffer().array();


      endpoint.broadcast(data);
   }


   public void run()

View Full Code Here


               HornetQBuffer bodyBuffer = HornetQBuffers.fixedBuffer(localChunkLen);


               context.encode(bodyBuffer, localChunkLen);


               byte[] body = bodyBuffer.toByteBuffer().array();


               int packetSize = callback.sendLargeMessageContinuation(id,
                                                                      body,
                                                                      positionPendingLargeMessage + localChunkLen < sizePendingLargeMessage,
                                                                      false);

View Full Code Here

            pos += chunkLength;


            lastChunk = pos >= bodySize;


            final SessionSendContinuationMessage chunk = new SessionSendContinuationMessage(msgI, 
                                                                                            bodyBuffer.toByteBuffer()
                                                                                                      .array(),
                                                                                            !lastChunk,
                                                                                            lastChunk && sendBlocking);


            if (sendBlocking && lastChunk)

View Full Code Here

            pos += chunkLength;


            lastChunk = pos >= bodySize;


            final SessionSendContinuationMessage chunk = new SessionSendContinuationMessage(msgI,
                                                                                            bodyBuffer.toByteBuffer()
                                                                                               .array(),
                                                                                            !lastChunk,
                                                                                            lastChunk && sendBlocking);


            if (sendBlocking && lastChunk)

View Full Code Here


               HornetQBuffer bodyBuffer = HornetQBuffers.fixedBuffer(localChunkLen);


               context.encode(bodyBuffer, localChunkLen);


               byte[] body = bodyBuffer.toByteBuffer().array();


               int packetSize = callback.sendLargeMessageContinuation(id,
                                                                      body,
                                                                      positionPendingLargeMessage + localChunkLen < sizePendingLargeMessage,
                                                                      false);

View Full Code Here


               HornetQBuffer bodyBuffer = HornetQBuffers.fixedBuffer(localChunkLen);


               context.encode(bodyBuffer, localChunkLen);


               byte[] body = bodyBuffer.toByteBuffer().array();


               int packetSize = callback.sendLargeMessageContinuation(id,
                                                                      body,
                                                                      positionPendingLargeMessage + localChunkLen < sizePendingLargeMessage,
                                                                      false);

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.