Interface LargeMessageController
-
- All Superinterfaces:
ActiveMQBuffer,DataInput
- All Known Implementing Classes:
LargeMessageControllerImpl
public interface LargeMessageController extends ActiveMQBuffer
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidaddPacket(byte[] chunk, int flowControlSize, boolean isContinues)voidcancel()Cancels this buffer.voidclose()Closes this buffer.voiddiscardUnusedPackets()Discards packets unused by this buffer.longgetSize()Returns the size of this buffer.voidsaveBuffer(OutputStream output)Saves this buffer to the specified output.voidsetOutputStream(OutputStream output)Sets the OutputStream of this buffer to the specified output.LargeMessageControllerImpl.LargeDatatake()booleanwaitCompletion(long timeWait)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 Detail
-
getSize
long getSize()
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
void setOutputStream(OutputStream output) throws ActiveMQException
Sets the OutputStream of this buffer to the specified output.- Throws:
ActiveMQException
-
saveBuffer
void saveBuffer(OutputStream output) throws ActiveMQException
Saves this buffer to the specified output. This is just a blocking version ofsetOutputStream(OutputStream).- Throws:
ActiveMQException
-
addPacket
void addPacket(byte[] chunk, int flowControlSize, boolean isContinues)
-
waitCompletion
boolean waitCompletion(long timeWait) throws ActiveMQExceptionWaits for the completion for the specified waiting time (in milliseconds).- Throws:
ActiveMQException
-
take
LargeMessageControllerImpl.LargeData take() throws InterruptedException
- Throws:
InterruptedException
-
-