Package 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
public class MessageInternalImpl
extends Object
implements MessageInternal

Deprecated.

Field Summary

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

AMQP_PROPERTY_PREDICATE, 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_INGRESS_TIMESTAMP, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIG_ROUTING_TYPE, 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, PREFIX_AMQP_ANNOTATIONS, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Constructor	Description
MessageInternalImpl(ICoreMessage message)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	bodyChanged()	Deprecated.
boolean	containsProperty(String key)	Deprecated.
boolean	containsProperty(SimpleString 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(String key)	Deprecated.
Boolean	getBooleanProperty(SimpleString key)	Deprecated.
io.netty.buffer.ByteBuf	getBuffer()	Deprecated.
Byte	getByteProperty(String key)	Deprecated.
Byte	getByteProperty(SimpleString key)	Deprecated.
byte[]	getBytesProperty(String key)	Deprecated.
byte[]	getBytesProperty(SimpleString key)	Deprecated.
Double	getDoubleProperty(String key)	Deprecated.
Double	getDoubleProperty(SimpleString 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(String key)	Deprecated.
Float	getFloatProperty(SimpleString key)	Deprecated.
int	getHeadersAndPropertiesEncodeSize()	Deprecated.
Integer	getIntProperty(String key)	Deprecated.
Integer	getIntProperty(SimpleString key)	Deprecated.
Long	getLongProperty(String key)	Deprecated.
Long	getLongProperty(SimpleString key)	Deprecated.
int	getMemoryEstimate()	Deprecated.
long	getMessageID()	Deprecated. Returns the messageID; the messageID is set when the message is handled by the server.
Object	getObjectProperty(String key)	Deprecated.
Object	getObjectProperty(SimpleString key)	Deprecated.
Object	getOwner()	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; values range from 0 (less priority) to 9 (more priority) inclusive.
Set<SimpleString>	getPropertyNames()	Deprecated. Returns all the names of the properties for this message.
String	getProtocolName()	Deprecated.
int	getRefCount()	Deprecated.
SimpleString	getReplyTo()	Deprecated.
Long	getScheduledDeliveryTime()	Deprecated. Used to calculate what is the delivery time.
Short	getShortProperty(String key)	Deprecated.
Short	getShortProperty(SimpleString key)	Deprecated.
SimpleString	getSimpleStringProperty(String key)	Deprecated.
SimpleString	getSimpleStringProperty(SimpleString key)	Deprecated.
String	getStringProperty(String key)	Deprecated.
String	getStringProperty(SimpleString key)	Deprecated.
long	getTimestamp()	Deprecated.
TypedProperties	getTypedProperties()	Deprecated.
int	getUsage()	Deprecated.
Object	getUserContext(Object key)	Deprecated. Used for user context data.
Object	getUserID()	Deprecated. This represents historically the JMSMessageID.
ActiveMQBuffer	getWholeBuffer()	Deprecated.
boolean	isDurable()	Deprecated. Returns whether this message is durable or not.
boolean	isPaged()	Deprecated.
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(String key, boolean value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putBooleanProperty(SimpleString key, boolean value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putByteProperty(String key, byte value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putByteProperty(SimpleString key, byte value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putBytesProperty(String key, byte[] value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putBytesProperty(SimpleString key, byte[] value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putCharProperty(String key, char value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putCharProperty(SimpleString key, char value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putDoubleProperty(String key, double value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putDoubleProperty(SimpleString key, double value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putFloatProperty(String key, float value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putFloatProperty(SimpleString key, float value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putIntProperty(String key, int value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putIntProperty(SimpleString key, int value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putLongProperty(String key, long value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putLongProperty(SimpleString key, long value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putObjectProperty(String key, Object value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putObjectProperty(SimpleString key, Object value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putShortProperty(String key, short value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putShortProperty(SimpleString key, short value)	Deprecated. Callers must call Message.reencode() in order to be sent to clients
Message	putStringProperty(String key, String value)	Deprecated. Puts a String property in this message.
Message	putStringProperty(SimpleString key, String value)	Deprecated.
Message	putStringProperty(SimpleString key, SimpleString value)	Deprecated.
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(String key)	Deprecated.
Object	removeProperty(SimpleString key)	Deprecated.
void	sendBuffer(io.netty.buffer.ByteBuf buffer, int deliveryCount)	Deprecated. Used to send this message to an encoded medium buffer.
Message	setAddress(String address)	Deprecated. Look at Message.setAddress(SimpleString) for the doc.
Message	setAddress(SimpleString address)	Deprecated. This will set the address on CoreMessage.
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.
void	setOwner(Object object)	Deprecated.
void	setPaged()	Deprecated.
Message	setPriority(byte priority)	Deprecated. Sets the message priority.
Message	setReplyTo(SimpleString address)	Deprecated.
Message	setTimestamp(long timestamp)	Deprecated.
void	setUserContext(Object key, Object value)	Deprecated. Used for user context data.
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. Opposite of Message.usageUp()
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, clearAMQPProperties, clearInternalProperties, getAnnotationString, getBodyBuffer, getBrokerProperty, getConnectionID, getCorrelationID, getDuplicateIDBytes, getDuplicateProperty, getExtraBytesProperty, getGroupID, getGroupSequence, getIngressTimestamp, getLastValueProperty, getObjectPropertyForFilter, getOriginalEstimate, getRoutingType, getStringBody, getType, getValidatedUserID, getWholeMessageSize, hasScheduledDeliveryTime, isExpired, isLargeMessage, putExtraBytesProperty, reencode, referenceOriginalMessage, rejectConsumer, removeAnnotation, removeExtraBytesProperty, routed, setAnnotation, setBrokerProperty, setConnectionID, setCorrelationID, setGroupID, setGroupID, setGroupSequence, setIngressTimestamp, setLastValueProperty, setRoutingType, setScheduledDeliveryTime, setType, setValidatedUserID, toCompositeData, toMap, toMap, toPropertyMap, toPropertyMap

Constructor Details

MessageInternalImpl

public MessageInternalImpl(ICoreMessage message)

Deprecated.

Method Details

getProtocolName

public String getProtocolName()

Deprecated.

Specified by:

getProtocolName in interface Message

setPaged

public void setPaged()

Deprecated.

Specified by:

setPaged in interface Message

isPaged

public boolean isPaged()

Deprecated.

Specified by:

isPaged in interface Message

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.

Description copied from interface: Message

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.

getBuffer

public io.netty.buffer.ByteBuf getBuffer()

Deprecated.

copy

public Message copy()

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

copy

public Message copy(long newID)

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

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.

Description copied from interface: Message

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

Specified by:

getMessageID in interface Message

Returns:

the messageID; the messageID is set when the message is handled by the server

setMessageID

public Message setMessageID(long id)

Deprecated.

Specified by:

setMessageID in interface Message

getExpiration

public long getExpiration()

Deprecated.

Description copied from interface: Message

Returns the expiration time of this message.

Specified by:

getExpiration in interface Message

Returns:

the expiration time of this message

setExpiration

public Message setExpiration(long expiration)

Deprecated.

Description copied from interface: Message

Sets the expiration of this message.

Specified by:

setExpiration in interface Message

Parameters:

expiration - expiration time

getUserID

public Object getUserID()

Deprecated.

Description copied from interface: Message

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.

Description copied from interface: Message

Returns whether this message is durable or not.

Specified by:

isDurable in interface Message

Returns:

whether this message is durable or not

setDurable

public Message setDurable(boolean durable)

Deprecated.

Description copied from interface: Message

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

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

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.

Description copied from interface: Message

Returns the message priority; values range from 0 (less priority) to 9 (more priority) inclusive.

Specified by:

getPriority in interface Message

Returns:

the message priority; values range from 0 (less priority) to 9 (more priority) inclusive

setPriority

public Message setPriority(byte priority)

Deprecated.

Description copied from interface: Message

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.

Description copied from interface: Message

Used to receive this message from an encoded medium buffer

Specified by:

receiveBuffer in interface Message

sendBuffer

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

Deprecated.

Description copied from interface: Message

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.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putBooleanProperty in interface Message

putByteProperty

public Message putByteProperty(String key,
 byte value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putByteProperty in interface Message

putBytesProperty

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

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putBytesProperty in interface Message

putShortProperty

public Message putShortProperty(String key,
 short value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putShortProperty in interface Message

putCharProperty

public Message putCharProperty(String key,
 char value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putCharProperty in interface Message

putIntProperty

public Message putIntProperty(String key,
 int value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putIntProperty in interface Message

putLongProperty

public Message putLongProperty(String key,
 long value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putLongProperty in interface Message

putFloatProperty

public Message putFloatProperty(String key,
 float value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putFloatProperty in interface Message

putDoubleProperty

public Message putDoubleProperty(String key,
 double value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putDoubleProperty in interface Message

putBooleanProperty

public Message putBooleanProperty(SimpleString key,
 boolean value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putBooleanProperty in interface Message

putByteProperty

public Message putByteProperty(SimpleString key,
 byte value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putByteProperty in interface Message

putBytesProperty

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

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putBytesProperty in interface Message

putShortProperty

public Message putShortProperty(SimpleString key,
 short value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putShortProperty in interface Message

putCharProperty

public Message putCharProperty(SimpleString key,
 char value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putCharProperty in interface Message

putIntProperty

public Message putIntProperty(SimpleString key,
 int value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putIntProperty in interface Message

putLongProperty

public Message putLongProperty(SimpleString key,
 long value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putLongProperty in interface Message

putFloatProperty

public Message putFloatProperty(SimpleString key,
 float value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putFloatProperty in interface Message

putDoubleProperty

public Message putDoubleProperty(SimpleString key,
 double value)

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

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.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

Specified by:

putObjectProperty in interface Message

Throws:

ActiveMQPropertyConversionException

putObjectProperty

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

Deprecated.

Description copied from interface: Message

Callers must call Message.reencode() in order to be sent to clients

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.

Description copied from interface: Message

Returns the size of the encoded message.

Specified by:

getEncodeSize in interface Message

Returns:

the size of the encoded message

getPropertyNames

public Set<SimpleString> getPropertyNames()

Deprecated.

Description copied from interface: Message

Returns all the names of the properties for this message.

Specified by:

getPropertyNames in interface Message

Returns:

all the names of the properties for this 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.

Description copied from interface: Message

Opposite of Message.usageUp()

Specified by:

usageDown in interface Message

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.

Description copied from interface: Message

This should make you convert your message into Core format.

Specified by:

toCore in interface Message

toCore

public ICoreMessage toCore(CoreMessageObjectPools coreMessageObjectPools)

Deprecated.

Description copied from interface: Message

This should make you convert your message into Core format.

Specified by:

toCore in interface Message

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

Throws:

ActiveMQException

getOwner

public Object getOwner()

Deprecated.

Specified by:

getOwner in interface Message

setOwner

public void setOwner(Object object)

Deprecated.

Specified by:

setOwner in interface Message

getUserContext

public Object getUserContext(Object key)

Deprecated.

Description copied from interface: Message

Used for user context data. Useful on interceptors.

Specified by:

getUserContext in interface Message

setUserContext

public void setUserContext(Object key,
 Object value)

Deprecated.

Description copied from interface: Message

Used for user context data. Useful on interceptors.

Specified by:

setUserContext in interface Message