public interface LargeMessageController extends HornetQBuffer
Modifier and Type | Method and Description |
---|---|
void |
addPacket(SessionReceiveContinuationMessage packet) |
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.
|
boolean |
waitCompletion(long timeWait)
Waits for the completion for the specified waiting time (in milliseconds).
|
capacity, channelBuffer, 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, readBytes, readChar, readDouble, readerIndex, readerIndex, readFloat, readInt, readLong, readNullableSimpleString, readNullableString, readShort, readSimpleString, readSlice, readString, readUnsignedByte, readUnsignedInt, readUnsignedShort, readUTF, 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, writeChar, writeDouble, writeFloat, writeInt, writeLong, writeNullableSimpleString, writeNullableString, writerIndex, writerIndex, writeShort, writeSimpleString, writeString, writeUTF
long getSize()
void discardUnusedPackets()
void close()
void cancel()
void setOutputStream(OutputStream output) throws HornetQException
HornetQException
void saveBuffer(OutputStream output) throws HornetQException
setOutputStream(OutputStream)
.HornetQException
void addPacket(SessionReceiveContinuationMessage packet)
boolean waitCompletion(long timeWait) throws HornetQException
HornetQException
Copyright © 2013 JBoss by Red Hat. All Rights Reserved.