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

Class ClientLargeMessageImpl

java.lang.Object

org.apache.activemq.artemis.core.message.impl.MessageImpl

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

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

All Implemented Interfaces:

ClientMessage, Message, ClientLargeMessageInternal, ClientMessageInternal, MessageInternal

public final 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.

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.client.impl.ClientMessageImpl

REPLYTO_HEADER_NAME

Fields inherited from class org.apache.activemq.artemis.core.message.impl.MessageImpl

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

Fields inherited from interface org.apache.activemq.artemis.api.core.Message

BYTES_TYPE, DEFAULT_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_CONTENT_TYPE, 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_ORIGINAL_QUEUE, HDR_SCHEDULED_DELIVERY_TIME, HDR_VALIDATED_USER, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Constructor and Description
ClientLargeMessageImpl()

Method Summary

Modifier and Type	Method and Description
void	checkCompletion() This can be optionally used to verify if the entire message has been received.
void	discardBody() Discard unused packets (used on large-message)
ActiveMQBuffer	getBodyBuffer() Returns the message body as an ActiveMQBuffer
int	getBodySize() Returns 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	retrieveExistingData(ClientMessageInternal clMessage)
void	saveToOutputStream(OutputStream out) Saves the content of the message to the OutputStream.
void	setLargeMessageController(LargeMessageController controller)
void	setLargeMessageSize(long largeMessageSize)
ClientLargeMessageImpl	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.apache.activemq.artemis.core.client.impl.ClientMessageImpl

acknowledge, getBodyEncoder, getBodyInputStream, getDeliveryCount, getFlowControlSize, individualAcknowledge, isCompressed, isServerMessage, onReceipt, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putCharProperty, putCharProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, setBodyInputStream, setDeliveryCount, setFlowControlSize, toString, writeBodyBufferBytes, writeBodyBufferString

Methods inherited from class org.apache.activemq.artemis.core.message.impl.MessageImpl

bodyChanged, bodyToString, containsProperty, containsProperty, copyHeadersAndProperties, createBody, decode, decodeFromBuffer, decodeHeadersAndProperties, encode, encodeHeadersAndProperties, equals, getAddress, getBodyBufferDuplicate, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getExpiration, getFloatProperty, getFloatProperty, getHeadersAndPropertiesEncodeSize, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPriority, getProperties, getPropertyNames, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getTypedProperties, getUserID, getWholeBuffer, hashCode, isDurable, isExpired, putTypedProperties, removeProperty, removeProperty, setAddress, setAddressTransient, setDurable, setExpiration, setPriority, setTimestamp, setType, setUserID, toMap, toPropertyMap

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.client.impl.ClientMessageInternal

getFlowControlSize, getProperties, isCompressed, onReceipt, setAddressTransient, setFlowControlSize

Methods inherited from interface org.apache.activemq.artemis.api.core.client.ClientMessage

acknowledge, getDeliveryCount, individualAcknowledge, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putCharProperty, putCharProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, setBodyInputStream, setDeliveryCount, writeBodyBufferBytes, writeBodyBufferString

Methods inherited from interface org.apache.activemq.artemis.api.core.Message

containsProperty, containsProperty, getAddress, getBodyBufferDuplicate, 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, putObjectProperty, putObjectProperty, removeProperty, removeProperty, setAddress, setDurable, setExpiration, setPriority, setTimestamp, setUserID, toMap, toPropertyMap

Constructor Detail

ClientLargeMessageImpl

public ClientLargeMessageImpl()

Method Detail

setLargeMessageSize

public void setLargeMessageSize(long largeMessageSize)

Specified by:

setLargeMessageSize in interface ClientLargeMessageInternal

Parameters:

largeMessageSize - the largeMessageSize to set

getLargeMessageSize

public long getLargeMessageSize()

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

checkCompletion

public void checkCompletion()
                     throws ActiveMQException

Description copied from interface: ClientMessage

This can be optionally used to verify if the entire message has been received. It won't have any effect on regular messages but it may be helpful on large messages. The use case for this is to make sure there won't be an exception while getting the buffer. Using getBodyBuffer directly would have the same effect but you could get a Runtime non checked Exception instead

Specified by:

checkCompletion in interface ClientMessage

Overrides:

checkCompletion in class MessageImpl

Throws:

ActiveMQException

getBodyBuffer

public ActiveMQBuffer getBodyBuffer()

Description copied from interface: Message

Returns the message body as an ActiveMQBuffer

Specified by:

getBodyBuffer in interface Message

Overrides:

getBodyBuffer in class MessageImpl

getBodySize

public int getBodySize()

Description copied from interface: ClientMessage

Returns 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 ActiveMQException

Description copied from interface: ClientMessage

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

Specified by:

saveToOutputStream in interface ClientMessage

Overrides:

saveToOutputStream in class ClientMessageImpl

Throws:

ActiveMQException

setOutputStream

public ClientLargeMessageImpl setOutputStream(OutputStream out)
                                       throws ActiveMQException

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

Returns:

this ClientMessage

Throws:

ActiveMQException

waitOutputStreamCompletion

public boolean waitOutputStreamCompletion(long timeMilliseconds)
                                   throws ActiveMQException

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:

ActiveMQException

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

retrieveExistingData

public void retrieveExistingData(ClientMessageInternal clMessage)