org.hornetq.core.client.impl

Class ClientLargeMessageImpl

java.lang.Object

org.hornetq.core.message.impl.MessageImpl

org.hornetq.core.client.impl.ClientMessageImpl

org.hornetq.core.client.impl.ClientLargeMessageImpl

All Implemented Interfaces:

ClientMessage, Message, ClientLargeMessageInternal, ClientMessageInternal, MessageInternal

public class ClientLargeMessageImpl
extends ClientMessageImpl
implements ClientLargeMessageInternal

ClientLargeMessageImpl is only created when receiving large messages. At the time of sending a regular Message is sent as we won't know the message is considered large until the buffer is filled up or the user set a streaming.

Author:

clebertsuconic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ClientLargeMessageImpl.HornetQOutputStream

Field Summary

Fields inherited from class org.hornetq.core.client.impl.ClientMessageImpl

REPLYTO_HEADER_NAME

Fields inherited from class org.hornetq.core.message.impl.MessageImpl

address, BODY_OFFSET, bodyBuffer, buffer, BUFFER_HEADER_SPACE, bufferValid, durable, expiration, HDR_BRIDGE_DUPLICATE_ID, HDR_ROUTE_TO_IDS, messageID, priority, properties, timestamp, type

Fields inherited from interface org.hornetq.api.core.Message

BYTES_TYPE, DEFAULT_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_DUPLICATE_DETECTION_ID, HDR_GROUP_ID, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_ADDRESS, HDR_SCHEDULED_DELIVERY_TIME, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Constructor and Description
ClientLargeMessageImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	discardBody() Discard unused packets (used on large-message)
HornetQBuffer	getBodyBuffer() Returns the message body as a HornetQBuffer
int	getBodySize() Return the size (in bytes) of this message's body
int	getEncodeSize() Returns the size of the encoded message.
LargeMessageController	getLargeMessageController()
long	getLargeMessageSize()
boolean	isLargeMessage() Returns whether this message is a large message or a regular message.
void	saveToOutputStream(OutputStream out) Saves the content of the message to the OutputStream.
void	setLargeMessageController(LargeMessageController controller)
void	setLargeMessageSize(long largeMessageSize)
void	setOutputStream(OutputStream out) Sets the OutputStream that will receive the content of a message received in a non blocking way.
boolean	waitOutputStreamCompletion(long timeMilliseconds) Wait the outputStream completion of the message.

Methods inherited from class org.hornetq.core.client.impl.ClientMessageImpl

acknowledge, getBodyEncoder, getBodyInputStream, getDeliveryCount, getFlowControlSize, isCompressed, isServerMessage, onReceipt, setBodyInputStream, setBuffer, setDeliveryCount, setFlowControlSize, toString

Methods inherited from class org.hornetq.core.message.impl.MessageImpl

bodyChanged, checkCopy, containsProperty, containsProperty, copyHeadersAndProperties, createBody, decode, decodeFromBuffer, decodeHeadersAndProperties, encode, encodeHeadersAndProperties, getAddress, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getExpiration, getFloatProperty, getFloatProperty, getHeadersAndPropertiesEncodeSize, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPriority, getPropertyNames, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getTypedProperties, getUserID, getWholeBuffer, isDurable, isExpired, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, putTypedProperties, removeProperty, removeProperty, resetCopied, setAddress, setAddressTransient, setDurable, setExpiration, setPriority, setTimestamp, setType, setUserID, toMap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.hornetq.core.client.impl.ClientMessageInternal

getFlowControlSize, isCompressed, onReceipt, setBuffer, setFlowControlSize

Methods inherited from interface org.hornetq.api.core.client.ClientMessage

acknowledge, getDeliveryCount, setBodyInputStream, setDeliveryCount

Methods inherited from interface org.hornetq.core.message.impl.MessageInternal

bodyChanged, checkCopy, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getBodyEncoder, getBodyInputStream, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getHeadersAndPropertiesEncodeSize, getTypedProperties, getWholeBuffer, isServerMessage, resetCopied, setAddressTransient

Methods inherited from interface org.hornetq.api.core.Message

containsProperty, containsProperty, getAddress, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getExpiration, getFloatProperty, getFloatProperty, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPriority, getPropertyNames, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getUserID, isDurable, isExpired, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, removeProperty, removeProperty, setAddress, setDurable, setExpiration, setPriority, setTimestamp, setUserID, toMap

Constructor Detail

ClientLargeMessageImpl

public ClientLargeMessageImpl()

Method Detail

getLargeMessageSize

public long getLargeMessageSize()

Specified by:

getLargeMessageSize in interface ClientLargeMessageInternal

Returns:

the largeMessageSize

setLargeMessageSize

public void setLargeMessageSize(long largeMessageSize)

Specified by:

setLargeMessageSize in interface ClientLargeMessageInternal

Parameters:

largeMessageSize - the largeMessageSize to set

getEncodeSize

public int getEncodeSize()

Description copied from interface: Message

Returns the size of the encoded message.

Specified by:

getEncodeSize in interface Message

Overrides:

getEncodeSize in class MessageImpl

isLargeMessage

public boolean isLargeMessage()

Description copied from interface: Message

Returns whether this message is a large message or a regular message.

Specified by:

isLargeMessage in interface Message

Overrides:

isLargeMessage in class ClientMessageImpl

Returns:

the largeMessage

setLargeMessageController

public void setLargeMessageController(LargeMessageController controller)

Specified by:

setLargeMessageController in interface ClientLargeMessageInternal

getBodyBuffer

public HornetQBuffer getBodyBuffer()

Description copied from interface: Message

Returns the message body as a HornetQBuffer

Specified by:

getBodyBuffer in interface Message

Overrides:

getBodyBuffer in class MessageImpl

getBodySize

public int getBodySize()

Description copied from interface: ClientMessage

Return the size (in bytes) of this message's body

Specified by:

getBodySize in interface ClientMessage

Overrides:

getBodySize in class ClientMessageImpl

getLargeMessageController

public LargeMessageController getLargeMessageController()

Specified by:

getLargeMessageController in interface ClientLargeMessageInternal

saveToOutputStream

public void saveToOutputStream(OutputStream out)
                        throws HornetQException

Description copied from interface: ClientMessage

Saves the content of the message to the OutputStream. It will block until the entire content is transfered to the OutputStream.

Specified by:

saveToOutputStream in interface ClientMessage

Overrides:

saveToOutputStream in class ClientMessageImpl

Throws:

HornetQException

setOutputStream

public void setOutputStream(OutputStream out)
                     throws HornetQException

Description copied from interface: ClientMessage

Sets the OutputStream that will receive the content of a message received in a non blocking way.
This method is used when consuming large messages

Specified by:

setOutputStream in interface ClientMessage

Overrides:

setOutputStream in class ClientMessageImpl

Throws:

HornetQException

waitOutputStreamCompletion

public boolean waitOutputStreamCompletion(long timeMilliseconds)
                                   throws HornetQException

Description copied from interface: ClientMessage

Wait the outputStream completion of the message. This method is used when consuming large messages

Specified by:

waitOutputStreamCompletion in interface ClientMessage

Overrides:

waitOutputStreamCompletion in class ClientMessageImpl

Parameters:

timeMilliseconds - - 0 means wait forever

Returns:

true if it reached the end

Throws:

HornetQException

discardBody

public void discardBody()

Description copied from interface: ClientMessageInternal

Discard unused packets (used on large-message)

Specified by:

discardBody in interface ClientMessageInternal

Overrides:

discardBody in class ClientMessageImpl