Package org.apache.activemq.artemis.core.client.impl

Interface LargeMessageController

All Superinterfaces:

ActiveMQBuffer, DataInput

All Known Implementing Classes:

LargeMessageControllerImpl

public interface LargeMessageController
extends ActiveMQBuffer

Method Summary

Modifier and Type	Method	Description
void	addPacket(byte[] chunk, int flowControlSize, boolean isContinues)
void	cancel()	Cancels this buffer.
void	close()	Closes this buffer.
void	discardUnusedPackets()	Discards packets unused by this buffer.
long	getSize()	Returns the size of this buffer..
void	saveBuffer(OutputStream output)	Saves this buffer to the specified output.
void	setOutputStream(OutputStream output)	Sets the OutputStream of this buffer to the specified output.
LargeMessageControllerImpl.LargeData	take()
boolean	waitCompletion(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

Methods inherited from interface java.io.DataInput

readFully, readFully, readLine

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

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 of setOutputStream(OutputStream).

Throws:

ActiveMQException

addPacket

void addPacket(byte[] chunk,
 int flowControlSize,
 boolean isContinues)

waitCompletion

boolean waitCompletion(long timeWait)
                throws ActiveMQException

Waits for the completion for the specified waiting time (in milliseconds).

Throws:

ActiveMQException

take

LargeMessageControllerImpl.LargeData take()
                                   throws InterruptedException

Throws:

InterruptedException