-
Method Summary
void
addPacket(byte[] chunk,
int flowControlSize,
boolean isContinues)
void
void
void
Discards packets unused by this buffer.
long
Returns the size of this buffer..
void
Saves this buffer to the specified output.
void
Sets the OutputStream of this buffer to the specified output.
boolean
Waits for the completion for the specified waiting time (in milliseconds).
Methods inherited from interface org.apache.activemq.artemis.api.core.ActiveMQBuffer
byteBuf, capacity, clear, copy, copy, discardReadBytes, duplicate, getByte, getBytes, getBytes, getBytes, getBytes, getBytes, getBytes, getChar, getDouble, getFloat, getInt, getLong, getShort, getUnsignedByte, getUnsignedInt, getUnsignedShort, markReaderIndex, markWriterIndex, readable, readableBytes, readBoolean, readByte, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readChar, readDouble, readerIndex, readerIndex, readFloat, readInt, readLong, readNullableBoolean, readNullableInt, readNullableLong, readNullableSimpleString, readNullableString, readShort, readSimpleString, readSlice, readString, readUnsignedByte, readUnsignedInt, readUnsignedShort, readUTF, release, resetReaderIndex, resetWriterIndex, setByte, setBytes, setBytes, setBytes, setBytes, setBytes, setBytes, setChar, setDouble, setFloat, setIndex, setInt, setLong, setShort, skipBytes, slice, slice, toByteBuffer, toByteBuffer, writable, writableBytes, writeBoolean, writeByte, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeChar, writeDouble, writeFloat, writeInt, writeLong, writeNullableBoolean, writeNullableInt, writeNullableLong, writeNullableSimpleString, writeNullableString, writerIndex, writerIndex, writeShort, writeSimpleString, writeString, writeUTF
-
Method Details
-
getSize
long getSize()
Returns the size of this buffer..
- Returns:
- the size of this buffer.
-
discardUnusedPackets
void discardUnusedPackets()
Discards packets unused by this buffer.
-
close
void close()
Closes this buffer.
-
cancel
void cancel()
Cancels this buffer.
-
setOutputStream
Sets the OutputStream of this buffer to the specified output.
- Throws:
ActiveMQException
-
-
addPacket
void addPacket(byte[] chunk,
int flowControlSize,
boolean isContinues)
-
waitCompletion
Waits for the completion for the specified waiting time (in milliseconds).
- Throws:
ActiveMQException
-