org.hornetq.core.client.impl
public class LargeMessageControllerImpl extends Object implements LargeMessageController
SessionReceiveContinuationMessage
s as it was being handled
by a single buffer. This buffer can be consumed as messages are arriving, and it will hold the
packets until they are read using the ChannelBuffer interface, or the setOutputStream or
saveStream are called.Constructor and Description |
---|
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
long totalSize,
long readTimeout) |
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
long totalSize,
long readTimeout,
File cachedFile) |
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
long totalSize,
long readTimeout,
File cachedFile,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
addPacket(SessionReceiveContinuationMessage packet)
Add a buff to the List, or save it to the OutputStream if set
|
void |
cancel()
Cancels this buffer.
|
int |
capacity() |
org.jboss.netty.buffer.ChannelBuffer |
channelBuffer() |
void |
clear() |
void |
close()
Closes this buffer.
|
HornetQBuffer |
copy() |
HornetQBuffer |
copy(int index,
int length) |
void |
discardReadBytes() |
void |
discardUnusedPackets()
Discards packets unused by this buffer.
|
HornetQBuffer |
duplicate() |
byte |
getByte(int index) |
void |
getBytes(int index,
byte[] dst) |
void |
getBytes(int index,
byte[] dst,
int dstIndex,
int length) |
void |
getBytes(int index,
ByteBuffer dst) |
int |
getBytes(int index,
GatheringByteChannel out,
int length) |
void |
getBytes(int index,
HornetQBuffer dst) |
void |
getBytes(int index,
HornetQBuffer dst,
int length) |
void |
getBytes(int index,
HornetQBuffer dst,
int dstIndex,
int length) |
void |
getBytes(int index,
OutputStream out,
int length) |
void |
getBytes(long index,
byte[] dst) |
void |
getBytes(long index,
byte[] dst,
int dstIndex,
int length) |
void |
getBytes(long index,
ByteBuffer dst) |
void |
getBytes(long index,
OutputStream out,
int length) |
char |
getChar(int index) |
double |
getDouble(int index) |
float |
getFloat(int index) |
int |
getInt(int index) |
int |
getInt(long index) |
long |
getLong(int index) |
long |
getLong(long index) |
int |
getMedium(int index) |
short |
getShort(int index) |
short |
getShort(long index) |
long |
getSize()
Returns the size of this buffer.
|
Object |
getUnderlyingBuffer() |
short |
getUnsignedByte(int index) |
long |
getUnsignedInt(int index) |
int |
getUnsignedMedium(long index) |
int |
getUnsignedShort(int index) |
void |
markReaderIndex() |
void |
markWriterIndex() |
boolean |
readable() |
int |
readableBytes() |
boolean |
readBoolean() |
byte |
readByte() |
void |
readBytes(byte[] dst) |
void |
readBytes(byte[] dst,
int dstIndex,
int length) |
void |
readBytes(ByteBuffer dst) |
int |
readBytes(GatheringByteChannel out,
int length) |
void |
readBytes(HornetQBuffer dst) |
void |
readBytes(HornetQBuffer dst,
int length) |
void |
readBytes(HornetQBuffer dst,
int dstIndex,
int length) |
HornetQBuffer |
readBytes(int length) |
void |
readBytes(OutputStream out,
int length) |
char |
readChar() |
double |
readDouble() |
int |
readerIndex() |
void |
readerIndex(int readerIndex) |
float |
readFloat() |
int |
readInt() |
int |
readInt(int pos) |
long |
readLong() |
int |
readMedium() |
SimpleString |
readNullableSimpleString() |
String |
readNullableString() |
short |
readShort() |
SimpleString |
readSimpleString() |
HornetQBuffer |
readSlice(int length) |
String |
readString() |
short |
readUnsignedByte() |
long |
readUnsignedInt() |
int |
readUnsignedMedium() |
int |
readUnsignedShort() |
String |
readUTF() |
void |
resetReaderIndex() |
void |
resetWriterIndex() |
void |
saveBuffer(OutputStream output)
Saves this buffer to the specified output.
|
void |
setByte(int index,
byte value) |
void |
setBytes(int index,
byte[] src) |
void |
setBytes(int index,
byte[] src,
int srcIndex,
int length) |
void |
setBytes(int index,
ByteBuffer src) |
void |
setBytes(int index,
HornetQBuffer src) |
void |
setBytes(int index,
HornetQBuffer src,
int length) |
void |
setBytes(int index,
HornetQBuffer src,
int srcIndex,
int length) |
void |
setChar(int index,
char value) |
void |
setDouble(int index,
double value) |
void |
setFloat(int index,
float value) |
void |
setIndex(int readerIndex,
int writerIndex) |
void |
setInt(int index,
int value) |
void |
setLocal(boolean local) |
void |
setLong(int index,
long value) |
void |
setOutputStream(OutputStream output)
Sets the OutputStream of this buffer to the specified output.
|
void |
setShort(int index,
short value) |
void |
setZero(int index,
int length) |
void |
skipBytes(int length) |
HornetQBuffer |
slice() |
HornetQBuffer |
slice(int index,
int length) |
ByteBuffer |
toByteBuffer() |
ByteBuffer |
toByteBuffer(int index,
int length) |
ByteBuffer[] |
toByteBuffers() |
ByteBuffer[] |
toByteBuffers(int index,
int length) |
String |
toString(String charsetName) |
boolean |
waitCompletion(long timeWait)
Waits for the completion for the specified waiting time (in milliseconds).
|
boolean |
writable() |
int |
writableBytes() |
void |
writeBoolean(boolean val) |
void |
writeByte(byte value) |
void |
writeBytes(byte[] src) |
void |
writeBytes(byte[] src,
int srcIndex,
int length) |
void |
writeBytes(ByteBuffer src) |
void |
writeBytes(HornetQBuffer src) |
void |
writeBytes(HornetQBuffer src,
int length) |
void |
writeBytes(HornetQBuffer src,
int srcIndex,
int length) |
int |
writeBytes(InputStream in,
int length) |
int |
writeBytes(ScatteringByteChannel in,
int length) |
void |
writeChar(char val) |
void |
writeDouble(double val) |
void |
writeFloat(float val) |
void |
writeInt(int value) |
void |
writeLong(long value) |
void |
writeMedium(int value) |
void |
writeNullableSimpleString(SimpleString val) |
void |
writeNullableString(String val) |
int |
writerIndex() |
void |
writerIndex(int writerIndex) |
void |
writeShort(short value) |
void |
writeSimpleString(SimpleString val) |
void |
writeString(String val) |
void |
writeUTF(String utf) |
void |
writeZero(int length) |
public LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout)
public LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout, File cachedFile)
public LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout, File cachedFile, int bufferSize)
public void setLocal(boolean local)
public void discardUnusedPackets()
LargeMessageController
discardUnusedPackets
in interface LargeMessageController
public void addPacket(SessionReceiveContinuationMessage packet)
addPacket
in interface LargeMessageController
packet
- public void cancel()
LargeMessageController
cancel
in interface LargeMessageController
public void close()
LargeMessageController
close
in interface LargeMessageController
public void setOutputStream(OutputStream output) throws HornetQException
LargeMessageController
setOutputStream
in interface LargeMessageController
HornetQException
public void saveBuffer(OutputStream output) throws HornetQException
LargeMessageController
LargeMessageController.setOutputStream(OutputStream)
.saveBuffer
in interface LargeMessageController
HornetQException
public boolean waitCompletion(long timeWait) throws HornetQException
LargeMessageController
waitCompletion
in interface LargeMessageController
timeWait
- Milliseconds to Wait. 0 means foreverException
HornetQException
public int capacity()
capacity
in interface HornetQBuffer
public byte readByte()
readByte
in interface HornetQBuffer
public byte getByte(int index)
getByte
in interface HornetQBuffer
public void getBytes(int index, HornetQBuffer dst, int dstIndex, int length)
getBytes
in interface HornetQBuffer
public void getBytes(int index, byte[] dst, int dstIndex, int length)
getBytes
in interface HornetQBuffer
public void getBytes(long index, byte[] dst, int dstIndex, int length)
public void getBytes(int index, ByteBuffer dst)
getBytes
in interface HornetQBuffer
public void getBytes(long index, ByteBuffer dst)
public void getBytes(int index, OutputStream out, int length) throws IOException
IOException
public void getBytes(long index, OutputStream out, int length) throws IOException
IOException
public int getBytes(int index, GatheringByteChannel out, int length) throws IOException
IOException
public int getInt(int index)
getInt
in interface HornetQBuffer
public int getInt(long index)
public long getLong(int index)
getLong
in interface HornetQBuffer
public long getLong(long index)
public short getShort(int index)
getShort
in interface HornetQBuffer
public short getShort(long index)
public int getUnsignedMedium(long index)
public void setByte(int index, byte value)
setByte
in interface HornetQBuffer
public void setBytes(int index, HornetQBuffer src, int srcIndex, int length)
setBytes
in interface HornetQBuffer
public void setBytes(int index, byte[] src, int srcIndex, int length)
setBytes
in interface HornetQBuffer
public void setBytes(int index, ByteBuffer src)
setBytes
in interface HornetQBuffer
public void setInt(int index, int value)
setInt
in interface HornetQBuffer
public void setLong(int index, long value)
setLong
in interface HornetQBuffer
public void setShort(int index, short value)
setShort
in interface HornetQBuffer
public ByteBuffer toByteBuffer(int index, int length)
toByteBuffer
in interface HornetQBuffer
public int readerIndex()
readerIndex
in interface HornetQBuffer
public void readerIndex(int readerIndex)
readerIndex
in interface HornetQBuffer
public int writerIndex()
writerIndex
in interface HornetQBuffer
public long getSize()
LargeMessageController
getSize
in interface LargeMessageController
public void writerIndex(int writerIndex)
writerIndex
in interface HornetQBuffer
public void setIndex(int readerIndex, int writerIndex)
setIndex
in interface HornetQBuffer
public void clear()
clear
in interface HornetQBuffer
public boolean readable()
readable
in interface HornetQBuffer
public boolean writable()
writable
in interface HornetQBuffer
public int readableBytes()
readableBytes
in interface HornetQBuffer
public int writableBytes()
writableBytes
in interface HornetQBuffer
public void markReaderIndex()
markReaderIndex
in interface HornetQBuffer
public void resetReaderIndex()
resetReaderIndex
in interface HornetQBuffer
public void markWriterIndex()
markWriterIndex
in interface HornetQBuffer
public void resetWriterIndex()
resetWriterIndex
in interface HornetQBuffer
public void discardReadBytes()
discardReadBytes
in interface HornetQBuffer
public short getUnsignedByte(int index)
getUnsignedByte
in interface HornetQBuffer
public int getUnsignedShort(int index)
getUnsignedShort
in interface HornetQBuffer
public int getMedium(int index)
public long getUnsignedInt(int index)
getUnsignedInt
in interface HornetQBuffer
public void getBytes(int index, byte[] dst)
getBytes
in interface HornetQBuffer
public void getBytes(long index, byte[] dst)
public void getBytes(int index, HornetQBuffer dst)
getBytes
in interface HornetQBuffer
public void getBytes(int index, HornetQBuffer dst, int length)
getBytes
in interface HornetQBuffer
public void setBytes(int index, byte[] src)
setBytes
in interface HornetQBuffer
public void setBytes(int index, HornetQBuffer src)
setBytes
in interface HornetQBuffer
public void setBytes(int index, HornetQBuffer src, int length)
setBytes
in interface HornetQBuffer
public void setZero(int index, int length)
public short readUnsignedByte()
readUnsignedByte
in interface HornetQBuffer
public short readShort()
readShort
in interface HornetQBuffer
public int readUnsignedShort()
readUnsignedShort
in interface HornetQBuffer
public int readMedium()
public int readUnsignedMedium()
public int readInt()
readInt
in interface HornetQBuffer
public int readInt(int pos)
public long readUnsignedInt()
readUnsignedInt
in interface HornetQBuffer
public long readLong()
readLong
in interface HornetQBuffer
public void readBytes(byte[] dst, int dstIndex, int length)
readBytes
in interface HornetQBuffer
public void readBytes(byte[] dst)
readBytes
in interface HornetQBuffer
public void readBytes(HornetQBuffer dst)
readBytes
in interface HornetQBuffer
public void readBytes(HornetQBuffer dst, int length)
readBytes
in interface HornetQBuffer
public void readBytes(HornetQBuffer dst, int dstIndex, int length)
readBytes
in interface HornetQBuffer
public void readBytes(ByteBuffer dst)
readBytes
in interface HornetQBuffer
public int readBytes(GatheringByteChannel out, int length) throws IOException
IOException
public void readBytes(OutputStream out, int length) throws IOException
IOException
public void skipBytes(int length)
skipBytes
in interface HornetQBuffer
public void writeByte(byte value)
writeByte
in interface HornetQBuffer
public void writeShort(short value)
writeShort
in interface HornetQBuffer
public void writeMedium(int value)
public void writeInt(int value)
writeInt
in interface HornetQBuffer
public void writeLong(long value)
writeLong
in interface HornetQBuffer
public void writeBytes(byte[] src, int srcIndex, int length)
writeBytes
in interface HornetQBuffer
public void writeBytes(byte[] src)
writeBytes
in interface HornetQBuffer
public void writeBytes(HornetQBuffer src)
public void writeBytes(HornetQBuffer src, int length)
writeBytes
in interface HornetQBuffer
public void writeBytes(ByteBuffer src)
writeBytes
in interface HornetQBuffer
public int writeBytes(InputStream in, int length) throws IOException
IOException
public int writeBytes(ScatteringByteChannel in, int length) throws IOException
IOException
public void writeZero(int length)
public ByteBuffer toByteBuffer()
toByteBuffer
in interface HornetQBuffer
public ByteBuffer[] toByteBuffers()
public ByteBuffer[] toByteBuffers(int index, int length)
public Object getUnderlyingBuffer()
public boolean readBoolean()
readBoolean
in interface HornetQBuffer
public char readChar()
readChar
in interface HornetQBuffer
public char getChar(int index)
getChar
in interface HornetQBuffer
public double getDouble(int index)
getDouble
in interface HornetQBuffer
public float getFloat(int index)
getFloat
in interface HornetQBuffer
public HornetQBuffer readBytes(int length)
readBytes
in interface HornetQBuffer
public double readDouble()
readDouble
in interface HornetQBuffer
public float readFloat()
readFloat
in interface HornetQBuffer
public SimpleString readNullableSimpleString()
readNullableSimpleString
in interface HornetQBuffer
public String readNullableString()
readNullableString
in interface HornetQBuffer
public SimpleString readSimpleString()
readSimpleString
in interface HornetQBuffer
public String readString()
readString
in interface HornetQBuffer
public String readUTF()
readUTF
in interface HornetQBuffer
public void writeBoolean(boolean val)
writeBoolean
in interface HornetQBuffer
public void writeChar(char val)
writeChar
in interface HornetQBuffer
public void writeDouble(double val)
writeDouble
in interface HornetQBuffer
public void writeFloat(float val)
writeFloat
in interface HornetQBuffer
public void writeNullableSimpleString(SimpleString val)
writeNullableSimpleString
in interface HornetQBuffer
public void writeNullableString(String val)
writeNullableString
in interface HornetQBuffer
public void writeSimpleString(SimpleString val)
writeSimpleString
in interface HornetQBuffer
public void writeString(String val)
writeString
in interface HornetQBuffer
public void writeUTF(String utf)
writeUTF
in interface HornetQBuffer
public HornetQBuffer copy()
copy
in interface HornetQBuffer
public HornetQBuffer slice(int index, int length)
slice
in interface HornetQBuffer
public org.jboss.netty.buffer.ChannelBuffer channelBuffer()
channelBuffer
in interface HornetQBuffer
public HornetQBuffer copy(int index, int length)
copy
in interface HornetQBuffer
public HornetQBuffer duplicate()
duplicate
in interface HornetQBuffer
public HornetQBuffer readSlice(int length)
readSlice
in interface HornetQBuffer
public void setChar(int index, char value)
setChar
in interface HornetQBuffer
public void setDouble(int index, double value)
setDouble
in interface HornetQBuffer
public void setFloat(int index, float value)
setFloat
in interface HornetQBuffer
public HornetQBuffer slice()
slice
in interface HornetQBuffer
public void writeBytes(HornetQBuffer src, int srcIndex, int length)
writeBytes
in interface HornetQBuffer
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.