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

Class MessageInternalImpl

java.lang.Object

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

All Implemented Interfaces:

Message, MessageInternal

Direct Known Subclasses:

ServerMessageImpl

Deprecated.

@Deprecated
public class MessageInternalImpl
extends Object
implements MessageInternal

Field Summary

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

BYTES_TYPE, DEFAULT_TYPE, EMBEDDED_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_BRIDGE_DUPLICATE_ID, HDR_CONTENT_TYPE, HDR_DUPLICATE_DETECTION_ID, HDR_GROUP_ID, HDR_GROUP_SEQUENCE, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_ADDRESS, HDR_ORIGINAL_QUEUE, HDR_PREFIX, HDR_ROUTE_TO_ACK_IDS, HDR_ROUTE_TO_IDS, HDR_ROUTING_TYPE, HDR_SCALEDOWN_TO_IDS, HDR_SCHEDULED_DELIVERY_TIME, HDR_VALIDATED_USER, INTERNAL_PROPERTY_NAMES_PREDICATE, LARGE_EMBEDDED_TYPE, MAP_TYPE, memoryOffset, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Constructor and Description
MessageInternalImpl(ICoreMessage message) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	bodyChanged() Deprecated.
boolean	containsProperty(SimpleString key) Deprecated.
boolean	containsProperty(String key) Deprecated.
Message	copy() Deprecated. It will generate a new instance of the message encode, being a deep copy, new properties, new everything
Message	copy(long newID) Deprecated. It will generate a new instance of the message encode, being a deep copy, new properties, new everything
Message	copy(long newID, boolean isDLQorExpiry) Deprecated. It will generate a new instance of the message encode, being a deep copy, new properties, new everything
void	decodeFromBuffer(ActiveMQBuffer buffer) Deprecated.
void	decodeHeadersAndProperties(ActiveMQBuffer buffer) Deprecated.
int	durableDown() Deprecated.
int	durableUp() Deprecated.
void	encodeHeadersAndProperties(ActiveMQBuffer buffer) Deprecated.
String	getAddress() Deprecated.
SimpleString	getAddressSimpleString() Deprecated.
Object	getAnnotation(SimpleString key) Deprecated.
BodyEncoder	getBodyEncoder() Deprecated.
InputStream	getBodyInputStream() Deprecated.
Boolean	getBooleanProperty(SimpleString key) Deprecated.
Boolean	getBooleanProperty(String key) Deprecated.
io.netty.buffer.ByteBuf	getBuffer() Deprecated.
Byte	getByteProperty(SimpleString key) Deprecated.
Byte	getByteProperty(String key) Deprecated.
byte[]	getBytesProperty(SimpleString key) Deprecated.
byte[]	getBytesProperty(String key) Deprecated.
Double	getDoubleProperty(SimpleString key) Deprecated.
Double	getDoubleProperty(String key) Deprecated.
int	getDurableCount() Deprecated.
ActiveMQBuffer	getEncodedBuffer() Deprecated.
int	getEncodeSize() Deprecated. Returns the size of the encoded message.
int	getEndOfBodyPosition() Deprecated.
int	getEndOfMessagePosition() Deprecated.
long	getExpiration() Deprecated. Returns the expiration time of this message.
Float	getFloatProperty(SimpleString key) Deprecated.
Float	getFloatProperty(String key) Deprecated.
int	getHeadersAndPropertiesEncodeSize() Deprecated.
Integer	getIntProperty(SimpleString key) Deprecated.
Integer	getIntProperty(String key) Deprecated.
Long	getLongProperty(SimpleString key) Deprecated.
Long	getLongProperty(String key) Deprecated.
int	getMemoryEstimate() Deprecated.
long	getMessageID() Deprecated. Returns the messageID.
Object	getObjectProperty(SimpleString key) Deprecated.
Object	getObjectProperty(String key) Deprecated.
long	getPersistentSize() Deprecated. This is the size of the message when persisted on disk which is used for metrics tracking Note that even if the message itself is not persisted on disk (ie non-durable) this value is still used for metrics tracking If a normal message it will be the encoded message size If a large message it will be encoded message size + large message body size
Persister<Message>	getPersister() Deprecated.
int	getPersistSize() Deprecated.
byte	getPriority() Deprecated. Returns the message priority.
Set<SimpleString>	getPropertyNames() Deprecated. Returns all the names of the properties for this message.
int	getRefCount() Deprecated.
SimpleString	getReplyTo() Deprecated.
Long	getScheduledDeliveryTime() Deprecated. Used to calculate what is the delivery time.
Short	getShortProperty(SimpleString key) Deprecated.
Short	getShortProperty(String key) Deprecated.
SimpleString	getSimpleStringProperty(SimpleString key) Deprecated.
SimpleString	getSimpleStringProperty(String key) Deprecated.
String	getStringProperty(SimpleString key) Deprecated.
String	getStringProperty(String key) Deprecated.
long	getTimestamp() Deprecated.
TypedProperties	getTypedProperties() Deprecated.
int	getUsage() Deprecated.
Object	getUserID() Deprecated. This represents historically the JMSMessageID.
ActiveMQBuffer	getWholeBuffer() Deprecated.
boolean	isDurable() Deprecated. Returns whether this message is durable or not.
boolean	isServerMessage() Deprecated.
void	messageChanged() Deprecated. WARNING: Calling this method on a AMQPMessage will allow the non mutable part of the message to be modified.
void	persist(ActiveMQBuffer targetRecord) Deprecated.
Message	putBooleanProperty(SimpleString key, boolean value) Deprecated.
Message	putBooleanProperty(String key, boolean value) Deprecated.
Message	putByteProperty(SimpleString key, byte value) Deprecated.
Message	putByteProperty(String key, byte value) Deprecated.
Message	putBytesProperty(SimpleString key, byte[] value) Deprecated.
Message	putBytesProperty(String key, byte[] value) Deprecated.
Message	putCharProperty(SimpleString key, char value) Deprecated.
Message	putCharProperty(String key, char value) Deprecated.
Message	putDoubleProperty(SimpleString key, double value) Deprecated.
Message	putDoubleProperty(String key, double value) Deprecated.
Message	putFloatProperty(SimpleString key, float value) Deprecated.
Message	putFloatProperty(String key, float value) Deprecated.
Message	putIntProperty(SimpleString key, int value) Deprecated.
Message	putIntProperty(String key, int value) Deprecated.
Message	putLongProperty(SimpleString key, long value) Deprecated.
Message	putLongProperty(String key, long value) Deprecated.
Message	putObjectProperty(SimpleString key, Object value) Deprecated.
Message	putObjectProperty(String key, Object value) Deprecated.
Message	putShortProperty(SimpleString key, short value) Deprecated.
Message	putShortProperty(String key, short value) Deprecated.
Message	putStringProperty(SimpleString key, SimpleString value) Deprecated.
Message	putStringProperty(SimpleString key, String value) Deprecated.
Message	putStringProperty(String key, String value) Deprecated. Puts a String property in this message.
void	receiveBuffer(io.netty.buffer.ByteBuf buffer) Deprecated. Used to receive this message from an encoded medium buffer
int	refDown() Deprecated.
int	refUp() Deprecated.
void	reloadPersistence(ActiveMQBuffer record, CoreMessageObjectPools pools) Deprecated.
Object	removeProperty(SimpleString key) Deprecated.
Object	removeProperty(String key) Deprecated.
void	sendBuffer(io.netty.buffer.ByteBuf buffer, int deliveryCount) Deprecated. Used to send this message to an encoded medium buffer.
Message	setAddress(SimpleString address) Deprecated. This will set the address on CoreMessage.
Message	setAddress(String address) Deprecated. Look at Message.setAddress(SimpleString) for the doc.
void	setAddressTransient(SimpleString address) Deprecated.
Message	setBuffer(io.netty.buffer.ByteBuf buffer) Deprecated. The buffer will belong to this message, until release is called.
Message	setDurable(boolean durable) Deprecated. Sets whether this message is durable or not.
Message	setExpiration(long expiration) Deprecated. Sets the expiration of this message.
Message	setMessageID(long id) Deprecated.
Message	setPriority(byte priority) Deprecated. Sets the message priority.
Message	setReplyTo(SimpleString address) Deprecated.
Message	setTimestamp(long timestamp) Deprecated.
Message	setUserID(Object userID) Deprecated.
ICoreMessage	toCore() Deprecated. This should make you convert your message into Core format.
ICoreMessage	toCore(CoreMessageObjectPools coreMessageObjectPools) Deprecated. This should make you convert your message into Core format.
int	usageDown() Deprecated.
int	usageUp() Deprecated. this method indicates usage by components such as large message or page cache.

Methods inherited from class java.lang.Object

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

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

acceptsConsumer, clearInternalProperties, getAnnotationString, getBodyBuffer, getBrokerProperty, getConnectionID, getCorrelationID, getDuplicateIDBytes, getDuplicateProperty, getExtraBytesProperty, getGroupID, getGroupSequence, getLastValueProperty, getObjectPropertyForFilter, getRoutingType, getType, getValidatedUserID, getWholeMessageSize, hasScheduledDeliveryTime, isExpired, isLargeMessage, putExtraBytesProperty, reencode, referenceOriginalMessage, rejectConsumer, releaseBuffer, removeAnnotation, removeExtraBytesProperty, setAnnotation, setBrokerProperty, setConnectionID, setCorrelationID, setGroupID, setGroupID, setGroupSequence, setLastValueProperty, setRoutingType, setScheduledDeliveryTime, setType, setValidatedUserID, toMap, toPropertyMap

Constructor Detail

MessageInternalImpl

public MessageInternalImpl(ICoreMessage message)

Deprecated.

Method Detail

decodeFromBuffer

public void decodeFromBuffer(ActiveMQBuffer buffer)

Deprecated.

Specified by:

decodeFromBuffer in interface MessageInternal

getEndOfMessagePosition

public int getEndOfMessagePosition()

Deprecated.

Specified by:

getEndOfMessagePosition in interface MessageInternal

getEndOfBodyPosition

public int getEndOfBodyPosition()

Deprecated.

Specified by:

getEndOfBodyPosition in interface MessageInternal

bodyChanged

public void bodyChanged()

Deprecated.

Specified by:

bodyChanged in interface MessageInternal

isServerMessage

public boolean isServerMessage()

Deprecated.

Specified by:

isServerMessage in interface MessageInternal

getEncodedBuffer

public ActiveMQBuffer getEncodedBuffer()

Deprecated.

Specified by:

getEncodedBuffer in interface MessageInternal

getHeadersAndPropertiesEncodeSize

public int getHeadersAndPropertiesEncodeSize()

Deprecated.

Specified by:

getHeadersAndPropertiesEncodeSize in interface MessageInternal

getWholeBuffer

public ActiveMQBuffer getWholeBuffer()

Deprecated.

Specified by:

getWholeBuffer in interface MessageInternal

encodeHeadersAndProperties

public void encodeHeadersAndProperties(ActiveMQBuffer buffer)

Deprecated.

Specified by:

encodeHeadersAndProperties in interface MessageInternal

decodeHeadersAndProperties

public void decodeHeadersAndProperties(ActiveMQBuffer buffer)

Deprecated.

Specified by:

decodeHeadersAndProperties in interface MessageInternal

getBodyEncoder

public BodyEncoder getBodyEncoder()
                           throws ActiveMQException

Deprecated.

Specified by:

getBodyEncoder in interface MessageInternal

Throws:

ActiveMQException

getBodyInputStream

public InputStream getBodyInputStream()

Deprecated.

Specified by:

getBodyInputStream in interface Message

Specified by:

getBodyInputStream in interface MessageInternal

messageChanged

public void messageChanged()

Deprecated.

Description copied from interface: Message

WARNING: Calling this method on a AMQPMessage will allow the non mutable part of the message to be modified.

Specified by:

messageChanged in interface Message

getScheduledDeliveryTime

public Long getScheduledDeliveryTime()

Deprecated.

Used to calculate what is the delivery time. Return null if not scheduled.

Specified by:

getScheduledDeliveryTime in interface Message

getReplyTo

public SimpleString getReplyTo()

Deprecated.

Specified by:

getReplyTo in interface Message

setReplyTo

public Message setReplyTo(SimpleString address)

Deprecated.

Specified by:

setReplyTo in interface Message

setBuffer

public Message setBuffer(io.netty.buffer.ByteBuf buffer)

Deprecated.

The buffer will belong to this message, until release is called.

Specified by:

setBuffer in interface Message

Parameters:

buffer -

getBuffer

public io.netty.buffer.ByteBuf getBuffer()

Deprecated.

Specified by:

getBuffer in interface Message

copy

public Message copy()

Deprecated.

It will generate a new instance of the message encode, being a deep copy, new properties, new everything

Specified by:

copy in interface Message

copy

public Message copy(long newID)

Deprecated.

It will generate a new instance of the message encode, being a deep copy, new properties, new everything

Specified by:

copy in interface Message

Parameters:

newID -

copy

public Message copy(long newID,
                    boolean isDLQorExpiry)

Deprecated.

Description copied from interface: Message

It will generate a new instance of the message encode, being a deep copy, new properties, new everything

Specified by:

copy in interface Message

getMessageID

public long getMessageID()

Deprecated.

Returns the messageID.
The messageID is set when the message is handled by the server.

Specified by:

getMessageID in interface Message

setMessageID

public Message setMessageID(long id)

Deprecated.

Specified by:

setMessageID in interface Message

getExpiration

public long getExpiration()

Deprecated.

Returns the expiration time of this message.

Specified by:

getExpiration in interface Message

setExpiration

public Message setExpiration(long expiration)

Deprecated.

Sets the expiration of this message.

Specified by:

setExpiration in interface Message

Parameters:

expiration - expiration time

getUserID

public Object getUserID()

Deprecated.

This represents historically the JMSMessageID. We had in the past used this for the MessageID that was sent on core messages... later on when we added AMQP this name clashed with AMQPMessage.getUserID();

Specified by:

getUserID in interface Message

Returns:

the user id

setUserID

public Message setUserID(Object userID)

Deprecated.

Specified by:

setUserID in interface Message

isDurable

public boolean isDurable()

Deprecated.

Returns whether this message is durable or not.

Specified by:

isDurable in interface Message

setDurable

public Message setDurable(boolean durable)

Deprecated.

Sets whether this message is durable or not.

Specified by:

setDurable in interface Message

Parameters:

durable - true to flag this message as durable, false else

getPersister

public Persister<Message> getPersister()

Deprecated.

Specified by:

getPersister in interface Message

getAddress

public String getAddress()

Deprecated.

Specified by:

getAddress in interface Message

setAddress

public Message setAddress(String address)

Deprecated.

Description copied from interface: Message

Look at Message.setAddress(SimpleString) for the doc.

Specified by:

setAddress in interface Message

Returns:

getAddressSimpleString

public SimpleString getAddressSimpleString()

Deprecated.

Specified by:

getAddressSimpleString in interface Message

setAddress

public Message setAddress(SimpleString address)

Deprecated.

Description copied from interface: Message

This will set the address on CoreMessage. Note for AMQPMessages: in AMQPMessages this will not really change the address on the message. Instead it will add a property on extraProperties which only transverse internally at the broker. Whatever you change here it won't affect anything towards the received message. If you wish to change AMQPMessages address you will have to do it directly at the AMQP Message, however beware that AMQPMessages are not supposed to be changed at the broker, so only do it if you know what you are doing.

Specified by:

setAddress in interface Message

Returns:

getTimestamp

public long getTimestamp()

Deprecated.

Specified by:

getTimestamp in interface Message

setTimestamp

public Message setTimestamp(long timestamp)

Deprecated.

Specified by:

setTimestamp in interface Message

getPriority

public byte getPriority()

Deprecated.

Returns the message priority.

Values range from 0 (less priority) to 9 (more priority) inclusive.

Specified by:

getPriority in interface Message

setPriority

public Message setPriority(byte priority)

Deprecated.

Sets the message priority.

Value must be between 0 and 9 inclusive.

Specified by:

setPriority in interface Message

Parameters:

priority - the new message priority

receiveBuffer

public void receiveBuffer(io.netty.buffer.ByteBuf buffer)

Deprecated.

Used to receive this message from an encoded medium buffer

Specified by:

receiveBuffer in interface Message

Parameters:

buffer -

sendBuffer

public void sendBuffer(io.netty.buffer.ByteBuf buffer,
                       int deliveryCount)

Deprecated.

Used to send this message to an encoded medium buffer.

Specified by:

sendBuffer in interface Message

Parameters:

buffer - the buffer used.

deliveryCount - Some protocols (AMQP) will have this as part of the message.

getPersistSize

public int getPersistSize()

Deprecated.

Specified by:

getPersistSize in interface Message

persist

public void persist(ActiveMQBuffer targetRecord)

Deprecated.

Specified by:

persist in interface Message

reloadPersistence

public void reloadPersistence(ActiveMQBuffer record,
                              CoreMessageObjectPools pools)

Deprecated.

Specified by:

reloadPersistence in interface Message

putBooleanProperty

public Message putBooleanProperty(String key,
                                  boolean value)

Deprecated.

Specified by:

putBooleanProperty in interface Message

putByteProperty

public Message putByteProperty(String key,
                               byte value)

Deprecated.

Specified by:

putByteProperty in interface Message

putBytesProperty

public Message putBytesProperty(String key,
                                byte[] value)

Deprecated.

Specified by:

putBytesProperty in interface Message

putShortProperty

public Message putShortProperty(String key,
                                short value)

Deprecated.

Specified by:

putShortProperty in interface Message

putCharProperty

public Message putCharProperty(String key,
                               char value)

Deprecated.

Specified by:

putCharProperty in interface Message

putIntProperty

public Message putIntProperty(String key,
                              int value)

Deprecated.

Specified by:

putIntProperty in interface Message

putLongProperty

public Message putLongProperty(String key,
                               long value)

Deprecated.

Specified by:

putLongProperty in interface Message

putFloatProperty

public Message putFloatProperty(String key,
                                float value)

Deprecated.

Specified by:

putFloatProperty in interface Message

putDoubleProperty

public Message putDoubleProperty(String key,
                                 double value)

Deprecated.

Specified by:

putDoubleProperty in interface Message

putBooleanProperty

public Message putBooleanProperty(SimpleString key,
                                  boolean value)

Deprecated.

Specified by:

putBooleanProperty in interface Message

putByteProperty

public Message putByteProperty(SimpleString key,
                               byte value)

Deprecated.

Specified by:

putByteProperty in interface Message

putBytesProperty

public Message putBytesProperty(SimpleString key,
                                byte[] value)

Deprecated.

Specified by:

putBytesProperty in interface Message

putShortProperty

public Message putShortProperty(SimpleString key,
                                short value)

Deprecated.

Specified by:

putShortProperty in interface Message

putCharProperty

public Message putCharProperty(SimpleString key,
                               char value)

Deprecated.

Specified by:

putCharProperty in interface Message

putIntProperty

public Message putIntProperty(SimpleString key,
                              int value)

Deprecated.

Specified by:

putIntProperty in interface Message

putLongProperty

public Message putLongProperty(SimpleString key,
                               long value)

Deprecated.

Specified by:

putLongProperty in interface Message

putFloatProperty

public Message putFloatProperty(SimpleString key,
                                float value)

Deprecated.

Specified by:

putFloatProperty in interface Message

putDoubleProperty

public Message putDoubleProperty(SimpleString key,
                                 double value)

Deprecated.

Specified by:

putDoubleProperty in interface Message

putStringProperty

public Message putStringProperty(String key,
                                 String value)

Deprecated.

Puts a String property in this message.

Specified by:

putStringProperty in interface Message

Parameters:

key - property name

value - property value

putObjectProperty

public Message putObjectProperty(String key,
                                 Object value)
                          throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

putObjectProperty in interface Message

Throws:

ActiveMQPropertyConversionException

putObjectProperty

public Message putObjectProperty(SimpleString key,
                                 Object value)
                          throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

putObjectProperty in interface Message

Throws:

ActiveMQPropertyConversionException

removeProperty

public Object removeProperty(String key)

Deprecated.

Specified by:

removeProperty in interface Message

containsProperty

public boolean containsProperty(String key)

Deprecated.

Specified by:

containsProperty in interface Message

getBooleanProperty

public Boolean getBooleanProperty(String key)
                           throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getBooleanProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getByteProperty

public Byte getByteProperty(String key)
                     throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getByteProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getDoubleProperty

public Double getDoubleProperty(String key)
                         throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getDoubleProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getIntProperty

public Integer getIntProperty(String key)
                       throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getIntProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getLongProperty

public Long getLongProperty(String key)
                     throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getLongProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getObjectProperty

public Object getObjectProperty(String key)

Deprecated.

Specified by:

getObjectProperty in interface Message

getShortProperty

public Short getShortProperty(String key)
                       throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getShortProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getFloatProperty

public Float getFloatProperty(String key)
                       throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getFloatProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getStringProperty

public String getStringProperty(String key)
                         throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getStringProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getSimpleStringProperty

public SimpleString getSimpleStringProperty(String key)
                                     throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getSimpleStringProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getBytesProperty

public byte[] getBytesProperty(String key)
                        throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getBytesProperty in interface Message

Throws:

ActiveMQPropertyConversionException

removeProperty

public Object removeProperty(SimpleString key)

Deprecated.

Specified by:

removeProperty in interface Message

containsProperty

public boolean containsProperty(SimpleString key)

Deprecated.

Specified by:

containsProperty in interface Message

getBooleanProperty

public Boolean getBooleanProperty(SimpleString key)
                           throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getBooleanProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getByteProperty

public Byte getByteProperty(SimpleString key)
                     throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getByteProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getDoubleProperty

public Double getDoubleProperty(SimpleString key)
                         throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getDoubleProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getIntProperty

public Integer getIntProperty(SimpleString key)
                       throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getIntProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getLongProperty

public Long getLongProperty(SimpleString key)
                     throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getLongProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getObjectProperty

public Object getObjectProperty(SimpleString key)

Deprecated.

Specified by:

getObjectProperty in interface Message

getAnnotation

public Object getAnnotation(SimpleString key)

Deprecated.

Specified by:

getAnnotation in interface Message

getShortProperty

public Short getShortProperty(SimpleString key)
                       throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getShortProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getFloatProperty

public Float getFloatProperty(SimpleString key)
                       throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getFloatProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getStringProperty

public String getStringProperty(SimpleString key)
                         throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getStringProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getSimpleStringProperty

public SimpleString getSimpleStringProperty(SimpleString key)
                                     throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getSimpleStringProperty in interface Message

Throws:

ActiveMQPropertyConversionException

getBytesProperty

public byte[] getBytesProperty(SimpleString key)
                        throws ActiveMQPropertyConversionException

Deprecated.

Specified by:

getBytesProperty in interface Message

Throws:

ActiveMQPropertyConversionException

putStringProperty

public Message putStringProperty(SimpleString key,
                                 SimpleString value)

Deprecated.

Specified by:

putStringProperty in interface Message

putStringProperty

public Message putStringProperty(SimpleString key,
                                 String value)

Deprecated.

Specified by:

putStringProperty in interface Message

getEncodeSize

public int getEncodeSize()

Deprecated.

Returns the size of the encoded message.

Specified by:

getEncodeSize in interface Message

getPropertyNames

public Set<SimpleString> getPropertyNames()

Deprecated.

Returns all the names of the properties for this message.

Specified by:

getPropertyNames in interface Message

getRefCount

public int getRefCount()

Deprecated.

Specified by:

getRefCount in interface Message

getDurableCount

public int getDurableCount()

Deprecated.

Specified by:

getDurableCount in interface Message

refUp

public int refUp()

Deprecated.

Specified by:

refUp in interface Message

refDown

public int refDown()

Deprecated.

Specified by:

refDown in interface Message

usageUp

public int usageUp()

Deprecated.

Description copied from interface: Message

this method indicates usage by components such as large message or page cache. This method will cause large messages to be held longer after the ack happened for instance.

Specified by:

usageUp in interface Message

usageDown

public int usageDown()

Deprecated.

Specified by:

usageDown in interface Message

Returns:

See Also:

Message.usageUp()

getUsage

public int getUsage()

Deprecated.

Specified by:

getUsage in interface Message

durableUp

public int durableUp()

Deprecated.

Specified by:

durableUp in interface Message

durableDown

public int durableDown()

Deprecated.

Specified by:

durableDown in interface Message

toCore

public ICoreMessage toCore()

Deprecated.

This should make you convert your message into Core format.

Specified by:

toCore in interface Message

toCore

public ICoreMessage toCore(CoreMessageObjectPools coreMessageObjectPools)

Deprecated.

This should make you convert your message into Core format.

Specified by:

toCore in interface Message

Parameters:

coreMessageObjectPools -

getMemoryEstimate

public int getMemoryEstimate()

Deprecated.

Specified by:

getMemoryEstimate in interface Message

setAddressTransient

public void setAddressTransient(SimpleString address)

Deprecated.

Specified by:

setAddressTransient in interface MessageInternal

getTypedProperties

public TypedProperties getTypedProperties()

Deprecated.

Specified by:

getTypedProperties in interface MessageInternal

getPersistentSize

public long getPersistentSize()
                       throws ActiveMQException

Deprecated.

Description copied from interface: Message

This is the size of the message when persisted on disk which is used for metrics tracking Note that even if the message itself is not persisted on disk (ie non-durable) this value is still used for metrics tracking If a normal message it will be the encoded message size If a large message it will be encoded message size + large message body size

Specified by:

getPersistentSize in interface Message

Returns:

Throws:

ActiveMQException