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
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, STREAM_TYPE, TEXT_TYPE
-
-
Constructor Summary
Constructors Constructor Description MessageInternalImpl(ICoreMessage message)Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidbodyChanged()Deprecated.booleancontainsProperty(String key)Deprecated.booleancontainsProperty(SimpleString key)Deprecated.Messagecopy()Deprecated.It will generate a new instance of the message encode, being a deep copy, new properties, new everythingMessagecopy(long newID)Deprecated.It will generate a new instance of the message encode, being a deep copy, new properties, new everythingMessagecopy(long newID, boolean isDLQorExpiry)Deprecated.It will generate a new instance of the message encode, being a deep copy, new properties, new everythingvoiddecodeFromBuffer(ActiveMQBuffer buffer)Deprecated.voiddecodeHeadersAndProperties(ActiveMQBuffer buffer)Deprecated.intdurableDown()Deprecated.intdurableUp()Deprecated.voidencodeHeadersAndProperties(ActiveMQBuffer buffer)Deprecated.StringgetAddress()Deprecated.SimpleStringgetAddressSimpleString()Deprecated.ObjectgetAnnotation(SimpleString key)Deprecated.BodyEncodergetBodyEncoder()Deprecated.InputStreamgetBodyInputStream()Deprecated.BooleangetBooleanProperty(String key)Deprecated.BooleangetBooleanProperty(SimpleString key)Deprecated.io.netty.buffer.ByteBufgetBuffer()Deprecated.BytegetByteProperty(String key)Deprecated.BytegetByteProperty(SimpleString key)Deprecated.byte[]getBytesProperty(String key)Deprecated.byte[]getBytesProperty(SimpleString key)Deprecated.DoublegetDoubleProperty(String key)Deprecated.DoublegetDoubleProperty(SimpleString key)Deprecated.intgetDurableCount()Deprecated.ActiveMQBuffergetEncodedBuffer()Deprecated.intgetEncodeSize()Deprecated.Returns the size of the encoded message.intgetEndOfBodyPosition()Deprecated.intgetEndOfMessagePosition()Deprecated.longgetExpiration()Deprecated.Returns the expiration time of this message.FloatgetFloatProperty(String key)Deprecated.FloatgetFloatProperty(SimpleString key)Deprecated.intgetHeadersAndPropertiesEncodeSize()Deprecated.IntegergetIntProperty(String key)Deprecated.IntegergetIntProperty(SimpleString key)Deprecated.LonggetLongProperty(String key)Deprecated.LonggetLongProperty(SimpleString key)Deprecated.intgetMemoryEstimate()Deprecated.longgetMessageID()Deprecated.Returns the messageID.ObjectgetObjectProperty(String key)Deprecated.ObjectgetObjectProperty(SimpleString key)Deprecated.ObjectgetOwner()Deprecated.longgetPersistentSize()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 sizePersister<Message>getPersister()Deprecated.intgetPersistSize()Deprecated.bytegetPriority()Deprecated.Returns the message priority.Set<SimpleString>getPropertyNames()Deprecated.Returns all the names of the properties for this message.StringgetProtocolName()Deprecated.intgetRefCount()Deprecated.SimpleStringgetReplyTo()Deprecated.LonggetScheduledDeliveryTime()Deprecated.Used to calculate what is the delivery time.ShortgetShortProperty(String key)Deprecated.ShortgetShortProperty(SimpleString key)Deprecated.SimpleStringgetSimpleStringProperty(String key)Deprecated.SimpleStringgetSimpleStringProperty(SimpleString key)Deprecated.StringgetStringProperty(String key)Deprecated.StringgetStringProperty(SimpleString key)Deprecated.longgetTimestamp()Deprecated.TypedPropertiesgetTypedProperties()Deprecated.intgetUsage()Deprecated.ObjectgetUserContext(Object key)Deprecated.Used for user context data.ObjectgetUserID()Deprecated.This represents historically the JMSMessageID.ActiveMQBuffergetWholeBuffer()Deprecated.booleanisDurable()Deprecated.Returns whether this message is durable or not.booleanisServerMessage()Deprecated.voidmessageChanged()Deprecated.WARNING: Calling this method on a AMQPMessage will allow the non mutable part of the message to be modified.voidpersist(ActiveMQBuffer targetRecord)Deprecated.MessageputBooleanProperty(String key, boolean value)Deprecated.MessageputBooleanProperty(SimpleString key, boolean value)Deprecated.MessageputByteProperty(String key, byte value)Deprecated.MessageputByteProperty(SimpleString key, byte value)Deprecated.MessageputBytesProperty(String key, byte[] value)Deprecated.MessageputBytesProperty(SimpleString key, byte[] value)Deprecated.MessageputCharProperty(String key, char value)Deprecated.MessageputCharProperty(SimpleString key, char value)Deprecated.MessageputDoubleProperty(String key, double value)Deprecated.MessageputDoubleProperty(SimpleString key, double value)Deprecated.MessageputFloatProperty(String key, float value)Deprecated.MessageputFloatProperty(SimpleString key, float value)Deprecated.MessageputIntProperty(String key, int value)Deprecated.MessageputIntProperty(SimpleString key, int value)Deprecated.MessageputLongProperty(String key, long value)Deprecated.MessageputLongProperty(SimpleString key, long value)Deprecated.MessageputObjectProperty(String key, Object value)Deprecated.MessageputObjectProperty(SimpleString key, Object value)Deprecated.MessageputShortProperty(String key, short value)Deprecated.MessageputShortProperty(SimpleString key, short value)Deprecated.MessageputStringProperty(String key, String value)Deprecated.Puts a String property in this message.MessageputStringProperty(SimpleString key, String value)Deprecated.MessageputStringProperty(SimpleString key, SimpleString value)Deprecated.voidreceiveBuffer(io.netty.buffer.ByteBuf buffer)Deprecated.Used to receive this message from an encoded medium bufferintrefDown()Deprecated.intrefUp()Deprecated.voidreloadPersistence(ActiveMQBuffer record, CoreMessageObjectPools pools)Deprecated.ObjectremoveProperty(String key)Deprecated.ObjectremoveProperty(SimpleString key)Deprecated.voidsendBuffer(io.netty.buffer.ByteBuf buffer, int deliveryCount)Deprecated.Used to send this message to an encoded medium buffer.MessagesetAddress(String address)Deprecated.Look atMessage.setAddress(SimpleString)for the doc.MessagesetAddress(SimpleString address)Deprecated.This will set the address on CoreMessage.voidsetAddressTransient(SimpleString address)Deprecated.MessagesetBuffer(io.netty.buffer.ByteBuf buffer)Deprecated.The buffer will belong to this message, until release is called.MessagesetDurable(boolean durable)Deprecated.Sets whether this message is durable or not.MessagesetExpiration(long expiration)Deprecated.Sets the expiration of this message.MessagesetMessageID(long id)Deprecated.voidsetOwner(Object object)Deprecated.MessagesetPriority(byte priority)Deprecated.Sets the message priority.MessagesetReplyTo(SimpleString address)Deprecated.MessagesetTimestamp(long timestamp)Deprecated.voidsetUserContext(Object key, Object value)Deprecated.Used for user context data.MessagesetUserID(Object userID)Deprecated.ICoreMessagetoCore()Deprecated.This should make you convert your message into Core format.ICoreMessagetoCore(CoreMessageObjectPools coreMessageObjectPools)Deprecated.This should make you convert your message into Core format.intusageDown()Deprecated.intusageUp()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, getIngressTimestamp, getLastValueProperty, getObjectPropertyForFilter, getRoutingType, getStringBody, getType, getValidatedUserID, getWholeMessageSize, hasScheduledDeliveryTime, isExpired, isLargeMessage, putExtraBytesProperty, reencode, referenceOriginalMessage, rejectConsumer, removeAnnotation, removeExtraBytesProperty, setAnnotation, setBrokerProperty, setConnectionID, setCorrelationID, setGroupID, setGroupID, setGroupSequence, setIngressTimestamp, setLastValueProperty, setRoutingType, setScheduledDeliveryTime, setType, setValidatedUserID, toCompositeData, toMap, toMap, toPropertyMap, toPropertyMap
-
-
-
-
Constructor Detail
-
MessageInternalImpl
public MessageInternalImpl(ICoreMessage message)
Deprecated.
-
-
Method Detail
-
getProtocolName
public String getProtocolName()
Deprecated.- Specified by:
getProtocolNamein interfaceMessage
-
decodeFromBuffer
public void decodeFromBuffer(ActiveMQBuffer buffer)
Deprecated.- Specified by:
decodeFromBufferin interfaceMessageInternal
-
getEndOfMessagePosition
public int getEndOfMessagePosition()
Deprecated.- Specified by:
getEndOfMessagePositionin interfaceMessageInternal
-
getEndOfBodyPosition
public int getEndOfBodyPosition()
Deprecated.- Specified by:
getEndOfBodyPositionin interfaceMessageInternal
-
bodyChanged
public void bodyChanged()
Deprecated.- Specified by:
bodyChangedin interfaceMessageInternal
-
isServerMessage
public boolean isServerMessage()
Deprecated.- Specified by:
isServerMessagein interfaceMessageInternal
-
getEncodedBuffer
public ActiveMQBuffer getEncodedBuffer()
Deprecated.- Specified by:
getEncodedBufferin interfaceMessageInternal
-
getHeadersAndPropertiesEncodeSize
public int getHeadersAndPropertiesEncodeSize()
Deprecated.- Specified by:
getHeadersAndPropertiesEncodeSizein interfaceMessageInternal
-
getWholeBuffer
public ActiveMQBuffer getWholeBuffer()
Deprecated.- Specified by:
getWholeBufferin interfaceMessageInternal
-
encodeHeadersAndProperties
public void encodeHeadersAndProperties(ActiveMQBuffer buffer)
Deprecated.- Specified by:
encodeHeadersAndPropertiesin interfaceMessageInternal
-
decodeHeadersAndProperties
public void decodeHeadersAndProperties(ActiveMQBuffer buffer)
Deprecated.- Specified by:
decodeHeadersAndPropertiesin interfaceMessageInternal
-
getBodyEncoder
public BodyEncoder getBodyEncoder() throws ActiveMQException
Deprecated.- Specified by:
getBodyEncoderin interfaceMessageInternal- Throws:
ActiveMQException
-
getBodyInputStream
public InputStream getBodyInputStream()
Deprecated.- Specified by:
getBodyInputStreamin interfaceMessage- Specified by:
getBodyInputStreamin interfaceMessageInternal
-
messageChanged
public void messageChanged()
Deprecated.Description copied from interface:MessageWARNING: Calling this method on a AMQPMessage will allow the non mutable part of the message to be modified.- Specified by:
messageChangedin interfaceMessage
-
getScheduledDeliveryTime
public Long getScheduledDeliveryTime()
Deprecated.Used to calculate what is the delivery time. Return null if not scheduled.- Specified by:
getScheduledDeliveryTimein interfaceMessage
-
getReplyTo
public SimpleString getReplyTo()
Deprecated.- Specified by:
getReplyToin interfaceMessage
-
setReplyTo
public Message setReplyTo(SimpleString address)
Deprecated.- Specified by:
setReplyToin interfaceMessage
-
setBuffer
public Message setBuffer(io.netty.buffer.ByteBuf buffer)
Deprecated.The buffer will belong to this message, until release is called.- Parameters:
buffer-
-
getBuffer
public io.netty.buffer.ByteBuf getBuffer()
Deprecated.
-
copy
public Message copy()
Deprecated.It will generate a new instance of the message encode, being a deep copy, new properties, new everything
-
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
-
copy
public Message copy(long newID, boolean isDLQorExpiry)
Deprecated.Description copied from interface:MessageIt will generate a new instance of the message encode, being a deep copy, new properties, new everything
-
getMessageID
public long getMessageID()
Deprecated.Returns the messageID.
The messageID is set when the message is handled by the server.- Specified by:
getMessageIDin interfaceMessage
-
setMessageID
public Message setMessageID(long id)
Deprecated.- Specified by:
setMessageIDin interfaceMessage
-
getExpiration
public long getExpiration()
Deprecated.Returns the expiration time of this message.- Specified by:
getExpirationin interfaceMessage
-
setExpiration
public Message setExpiration(long expiration)
Deprecated.Sets the expiration of this message.- Specified by:
setExpirationin interfaceMessage- 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();
-
isDurable
public boolean isDurable()
Deprecated.Returns whether this message is durable or not.
-
setDurable
public Message setDurable(boolean durable)
Deprecated.Sets whether this message is durable or not.- Specified by:
setDurablein interfaceMessage- Parameters:
durable-trueto flag this message as durable,falseelse
-
getPersister
public Persister<Message> getPersister()
Deprecated.- Specified by:
getPersisterin interfaceMessage
-
getAddress
public String getAddress()
Deprecated.- Specified by:
getAddressin interfaceMessage
-
setAddress
public Message setAddress(String address)
Deprecated.Description copied from interface:MessageLook atMessage.setAddress(SimpleString)for the doc.- Specified by:
setAddressin interfaceMessage- Returns:
-
getAddressSimpleString
public SimpleString getAddressSimpleString()
Deprecated.- Specified by:
getAddressSimpleStringin interfaceMessage
-
setAddress
public Message setAddress(SimpleString address)
Deprecated.Description copied from interface:MessageThis 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:
setAddressin interfaceMessage- Returns:
-
getTimestamp
public long getTimestamp()
Deprecated.- Specified by:
getTimestampin interfaceMessage
-
setTimestamp
public Message setTimestamp(long timestamp)
Deprecated.- Specified by:
setTimestampin interfaceMessage
-
getPriority
public byte getPriority()
Deprecated.Returns the message priority.Values range from 0 (less priority) to 9 (more priority) inclusive.
- Specified by:
getPriorityin interfaceMessage
-
setPriority
public Message setPriority(byte priority)
Deprecated.Sets the message priority.Value must be between 0 and 9 inclusive.
- Specified by:
setPriorityin interfaceMessage- 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:
receiveBufferin interfaceMessage- 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:
sendBufferin interfaceMessage- Parameters:
buffer- the buffer used.deliveryCount- Some protocols (AMQP) will have this as part of the message.
-
getPersistSize
public int getPersistSize()
Deprecated.- Specified by:
getPersistSizein interfaceMessage
-
persist
public void persist(ActiveMQBuffer targetRecord)
Deprecated.
-
reloadPersistence
public void reloadPersistence(ActiveMQBuffer record, CoreMessageObjectPools pools)
Deprecated.- Specified by:
reloadPersistencein interfaceMessage
-
putBooleanProperty
public Message putBooleanProperty(String key, boolean value)
Deprecated.- Specified by:
putBooleanPropertyin interfaceMessage
-
putByteProperty
public Message putByteProperty(String key, byte value)
Deprecated.- Specified by:
putBytePropertyin interfaceMessage
-
putBytesProperty
public Message putBytesProperty(String key, byte[] value)
Deprecated.- Specified by:
putBytesPropertyin interfaceMessage
-
putShortProperty
public Message putShortProperty(String key, short value)
Deprecated.- Specified by:
putShortPropertyin interfaceMessage
-
putCharProperty
public Message putCharProperty(String key, char value)
Deprecated.- Specified by:
putCharPropertyin interfaceMessage
-
putIntProperty
public Message putIntProperty(String key, int value)
Deprecated.- Specified by:
putIntPropertyin interfaceMessage
-
putLongProperty
public Message putLongProperty(String key, long value)
Deprecated.- Specified by:
putLongPropertyin interfaceMessage
-
putFloatProperty
public Message putFloatProperty(String key, float value)
Deprecated.- Specified by:
putFloatPropertyin interfaceMessage
-
putDoubleProperty
public Message putDoubleProperty(String key, double value)
Deprecated.- Specified by:
putDoublePropertyin interfaceMessage
-
putBooleanProperty
public Message putBooleanProperty(SimpleString key, boolean value)
Deprecated.- Specified by:
putBooleanPropertyin interfaceMessage
-
putByteProperty
public Message putByteProperty(SimpleString key, byte value)
Deprecated.- Specified by:
putBytePropertyin interfaceMessage
-
putBytesProperty
public Message putBytesProperty(SimpleString key, byte[] value)
Deprecated.- Specified by:
putBytesPropertyin interfaceMessage
-
putShortProperty
public Message putShortProperty(SimpleString key, short value)
Deprecated.- Specified by:
putShortPropertyin interfaceMessage
-
putCharProperty
public Message putCharProperty(SimpleString key, char value)
Deprecated.- Specified by:
putCharPropertyin interfaceMessage
-
putIntProperty
public Message putIntProperty(SimpleString key, int value)
Deprecated.- Specified by:
putIntPropertyin interfaceMessage
-
putLongProperty
public Message putLongProperty(SimpleString key, long value)
Deprecated.- Specified by:
putLongPropertyin interfaceMessage
-
putFloatProperty
public Message putFloatProperty(SimpleString key, float value)
Deprecated.- Specified by:
putFloatPropertyin interfaceMessage
-
putDoubleProperty
public Message putDoubleProperty(SimpleString key, double value)
Deprecated.- Specified by:
putDoublePropertyin interfaceMessage
-
putStringProperty
public Message putStringProperty(String key, String value)
Deprecated.Puts a String property in this message.- Specified by:
putStringPropertyin interfaceMessage- Parameters:
key- property namevalue- property value
-
putObjectProperty
public Message putObjectProperty(String key, Object value) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
putObjectPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
putObjectProperty
public Message putObjectProperty(SimpleString key, Object value) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
putObjectPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
removeProperty
public Object removeProperty(String key)
Deprecated.- Specified by:
removePropertyin interfaceMessage
-
containsProperty
public boolean containsProperty(String key)
Deprecated.- Specified by:
containsPropertyin interfaceMessage
-
getBooleanProperty
public Boolean getBooleanProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getBooleanPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getByteProperty
public Byte getByteProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getBytePropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getDoubleProperty
public Double getDoubleProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getDoublePropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getIntProperty
public Integer getIntProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getIntPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getLongProperty
public Long getLongProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getLongPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getObjectProperty
public Object getObjectProperty(String key)
Deprecated.- Specified by:
getObjectPropertyin interfaceMessage
-
getShortProperty
public Short getShortProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getShortPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getFloatProperty
public Float getFloatProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getFloatPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getStringProperty
public String getStringProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getStringPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getSimpleStringProperty
public SimpleString getSimpleStringProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getSimpleStringPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getBytesProperty
public byte[] getBytesProperty(String key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getBytesPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
removeProperty
public Object removeProperty(SimpleString key)
Deprecated.- Specified by:
removePropertyin interfaceMessage
-
containsProperty
public boolean containsProperty(SimpleString key)
Deprecated.- Specified by:
containsPropertyin interfaceMessage
-
getBooleanProperty
public Boolean getBooleanProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getBooleanPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getByteProperty
public Byte getByteProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getBytePropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getDoubleProperty
public Double getDoubleProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getDoublePropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getIntProperty
public Integer getIntProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getIntPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getLongProperty
public Long getLongProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getLongPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getObjectProperty
public Object getObjectProperty(SimpleString key)
Deprecated.- Specified by:
getObjectPropertyin interfaceMessage
-
getAnnotation
public Object getAnnotation(SimpleString key)
Deprecated.- Specified by:
getAnnotationin interfaceMessage
-
getShortProperty
public Short getShortProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getShortPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getFloatProperty
public Float getFloatProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getFloatPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getStringProperty
public String getStringProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getStringPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getSimpleStringProperty
public SimpleString getSimpleStringProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getSimpleStringPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
getBytesProperty
public byte[] getBytesProperty(SimpleString key) throws ActiveMQPropertyConversionException
Deprecated.- Specified by:
getBytesPropertyin interfaceMessage- Throws:
ActiveMQPropertyConversionException
-
putStringProperty
public Message putStringProperty(SimpleString key, SimpleString value)
Deprecated.- Specified by:
putStringPropertyin interfaceMessage
-
putStringProperty
public Message putStringProperty(SimpleString key, String value)
Deprecated.- Specified by:
putStringPropertyin interfaceMessage
-
getEncodeSize
public int getEncodeSize()
Deprecated.Returns the size of the encoded message.- Specified by:
getEncodeSizein interfaceMessage
-
getPropertyNames
public Set<SimpleString> getPropertyNames()
Deprecated.Returns all the names of the properties for this message.- Specified by:
getPropertyNamesin interfaceMessage
-
getRefCount
public int getRefCount()
Deprecated.- Specified by:
getRefCountin interfaceMessage
-
getDurableCount
public int getDurableCount()
Deprecated.- Specified by:
getDurableCountin interfaceMessage
-
usageUp
public int usageUp()
Deprecated.Description copied from interface:Messagethis 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.
-
usageDown
public int usageDown()
Deprecated.- Specified by:
usageDownin interfaceMessage- Returns:
- See Also:
Message.usageUp()
-
durableDown
public int durableDown()
Deprecated.- Specified by:
durableDownin interfaceMessage
-
toCore
public ICoreMessage toCore()
Deprecated.This should make you convert your message into Core format.
-
toCore
public ICoreMessage toCore(CoreMessageObjectPools coreMessageObjectPools)
Deprecated.This should make you convert your message into Core format.
-
getMemoryEstimate
public int getMemoryEstimate()
Deprecated.- Specified by:
getMemoryEstimatein interfaceMessage
-
setAddressTransient
public void setAddressTransient(SimpleString address)
Deprecated.- Specified by:
setAddressTransientin interfaceMessageInternal
-
getTypedProperties
public TypedProperties getTypedProperties()
Deprecated.- Specified by:
getTypedPropertiesin interfaceMessageInternal
-
getPersistentSize
public long getPersistentSize() throws ActiveMQExceptionDeprecated.Description copied from interface:MessageThis 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:
getPersistentSizein interfaceMessage- Returns:
- Throws:
ActiveMQException
-
setOwner
public void setOwner(Object object)
Deprecated.
-
getUserContext
public Object getUserContext(Object key)
Deprecated.Description copied from interface:MessageUsed for user context data. Useful on interceptors.- Specified by:
getUserContextin interfaceMessage
-
setUserContext
public void setUserContext(Object key, Object value)
Deprecated.Description copied from interface:MessageUsed for user context data. Useful on interceptors.- Specified by:
setUserContextin interfaceMessage
-
-