org.apache.activemq.artemis.core.server.transformer

Class ServerMessageImpl

java.lang.Object

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

org.apache.activemq.artemis.core.server.transformer.ServerMessageImpl

All Implemented Interfaces:

Message, MessageInternal, ServerMessage

Deprecated.

@Deprecated
public class ServerMessageImpl
extends MessageInternalImpl
implements ServerMessage

Do not use this class. It is for backwards compatibility with Artemis 1.x only.

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
ServerMessageImpl(Message message) Deprecated.

Method Summary

Modifier and Type	Method and Description
ServerMessage	copy() Deprecated. It will generate a new instance of the message encode, being a deep copy, new properties, new everything
ServerMessage	copy(long newID) Deprecated. It will generate a new instance of the message encode, being a deep copy, new properties, new everything
MessageReference	createReference(Queue queue) Deprecated.
int	durableDown() Deprecated.
int	durableUp() Deprecated.
void	encodeMessageIDToBuffer() Deprecated.
void	forceAddress(SimpleString address) Deprecated. This will force encoding of the address, and will re-check the buffer This is to avoid setMessageTransient which set the address without changing the buffer
byte[]	getDuplicateIDBytes() Deprecated. it will translate a property named HDR_DUPLICATE_DETECTION_ID.
Object	getDuplicateProperty() Deprecated.
ICoreMessage	getICoreMessage() Deprecated.
int	getMemoryEstimate() Deprecated.
PagingStore	getPagingStore() Deprecated.
int	getRefCount() Deprecated.
boolean	isValid() Deprecated.
ServerMessage	makeCopyForExpiryOrDLA(long newID, MessageReference originalReference, boolean expiry, boolean copyOriginalHeaders) Deprecated.
int	refDown() Deprecated.
int	refUp() Deprecated.
ServerMessage	setMessageID(long id) Deprecated.
void	setOriginalHeaders(ServerMessage otherServerMessage, MessageReference originalReference, boolean expiry) Deprecated.
void	setPagingStore(PagingStore store) Deprecated.
boolean	storeIsPaging() Deprecated.

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

bodyChanged, containsProperty, containsProperty, copy, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getAddress, getAddressSimpleString, getAnnotation, getBodyEncoder, getBodyInputStream, getBooleanProperty, getBooleanProperty, getBuffer, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getDurableCount, getEncodedBuffer, getEncodeSize, getEndOfBodyPosition, getEndOfMessagePosition, getExpiration, getFloatProperty, getFloatProperty, getHeadersAndPropertiesEncodeSize, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPersistentSize, getPersister, getPersistSize, getPriority, getPropertyNames, getReplyTo, getScheduledDeliveryTime, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getTypedProperties, getUsage, getUserID, getWholeBuffer, isDurable, isServerMessage, messageChanged, persist, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putCharProperty, putCharProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, putStringProperty, receiveBuffer, reloadPersistence, removeProperty, removeProperty, sendBuffer, setAddress, setAddress, setAddressTransient, setBuffer, setDurable, setExpiration, setPriority, setReplyTo, setTimestamp, setUserID, toCore, toCore, usageDown, usageUp

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.core.message.impl.MessageInternal

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

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

acceptsConsumer, clearInternalProperties, containsProperty, containsProperty, copy, getAddress, getAddressSimpleString, getAnnotation, getAnnotationString, getBodyBuffer, getBooleanProperty, getBooleanProperty, getBrokerProperty, getBuffer, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getConnectionID, getCorrelationID, getDoubleProperty, getDoubleProperty, getDurableCount, getEncodeSize, getExpiration, getExtraBytesProperty, getFloatProperty, getFloatProperty, getGroupID, getGroupSequence, getIntProperty, getIntProperty, getLastValueProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getObjectPropertyForFilter, getPersistentSize, getPersister, getPersistSize, getPriority, getPropertyNames, getReplyTo, getRoutingType, getScheduledDeliveryTime, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getUsage, getUserID, getValidatedUserID, getWholeMessageSize, hasScheduledDeliveryTime, isDurable, isExpired, isLargeMessage, messageChanged, persist, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putCharProperty, putCharProperty, putDoubleProperty, putDoubleProperty, putExtraBytesProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, putStringProperty, receiveBuffer, reencode, referenceOriginalMessage, rejectConsumer, releaseBuffer, reloadPersistence, removeAnnotation, removeExtraBytesProperty, removeProperty, removeProperty, sendBuffer, setAddress, setAddress, setAnnotation, setBrokerProperty, setBuffer, setConnectionID, setCorrelationID, setDurable, setExpiration, setGroupID, setGroupID, setGroupSequence, setLastValueProperty, setPriority, setReplyTo, setRoutingType, setScheduledDeliveryTime, setTimestamp, setType, setUserID, setValidatedUserID, toCore, toCore, toMap, toPropertyMap, usageDown, usageUp

Constructor Detail

ServerMessageImpl

public ServerMessageImpl(Message message)

Deprecated.

Method Detail

isValid

public boolean isValid()

Deprecated.

getICoreMessage

public ICoreMessage getICoreMessage()

Deprecated.

Specified by:

getICoreMessage in interface ServerMessage

setMessageID

public ServerMessage setMessageID(long id)

Deprecated.

Specified by:

setMessageID in interface Message

Overrides:

setMessageID in class MessageInternalImpl

createReference

public MessageReference createReference(Queue queue)

Deprecated.

Specified by:

createReference in interface ServerMessage

forceAddress

public void forceAddress(SimpleString address)

Deprecated.

This will force encoding of the address, and will re-check the buffer This is to avoid setMessageTransient which set the address without changing the buffer

Specified by:

forceAddress in interface ServerMessage

Parameters:

address -

refUp

public int refUp()

Deprecated.

Specified by:

refUp in interface Message

Overrides:

refUp in class MessageInternalImpl

refDown

public int refDown()

Deprecated.

Specified by:

refDown in interface Message

Overrides:

refDown in class MessageInternalImpl

durableUp

public int durableUp()

Deprecated.

Specified by:

durableUp in interface Message

Overrides:

durableUp in class MessageInternalImpl

durableDown

public int durableDown()

Deprecated.

Specified by:

durableDown in interface Message

Overrides:

durableDown in class MessageInternalImpl

copy

public ServerMessage copy(long newID)

Deprecated.

Description copied from class: MessageInternalImpl

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

Specified by:

copy in interface Message

Overrides:

copy in class MessageInternalImpl

copy

public ServerMessage copy()

Deprecated.

Description copied from class: MessageInternalImpl

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

Specified by:

copy in interface Message

Overrides:

copy in class MessageInternalImpl

getMemoryEstimate

public int getMemoryEstimate()

Deprecated.

Specified by:

getMemoryEstimate in interface Message

Overrides:

getMemoryEstimate in class MessageInternalImpl

getRefCount

public int getRefCount()

Deprecated.

Specified by:

getRefCount in interface Message

Overrides:

getRefCount in class MessageInternalImpl

makeCopyForExpiryOrDLA

public ServerMessage makeCopyForExpiryOrDLA(long newID,
                                            MessageReference originalReference,
                                            boolean expiry,
                                            boolean copyOriginalHeaders)
                                     throws Exception

Deprecated.

Specified by:

makeCopyForExpiryOrDLA in interface ServerMessage

Throws:

Exception

setOriginalHeaders

public void setOriginalHeaders(ServerMessage otherServerMessage,
                               MessageReference originalReference,
                               boolean expiry)

Deprecated.

Specified by:

setOriginalHeaders in interface ServerMessage

setPagingStore

public void setPagingStore(PagingStore store)

Deprecated.

Specified by:

setPagingStore in interface ServerMessage

getPagingStore

public PagingStore getPagingStore()

Deprecated.

Specified by:

getPagingStore in interface ServerMessage

storeIsPaging

public boolean storeIsPaging()

Deprecated.

Specified by:

storeIsPaging in interface ServerMessage

encodeMessageIDToBuffer

public void encodeMessageIDToBuffer()

Deprecated.

Specified by:

encodeMessageIDToBuffer in interface ServerMessage

getDuplicateIDBytes

public byte[] getDuplicateIDBytes()

Deprecated.

Description copied from interface: Message

it will translate a property named HDR_DUPLICATE_DETECTION_ID.

Specified by:

getDuplicateIDBytes in interface Message

Returns:

getDuplicateProperty

public Object getDuplicateProperty()

Deprecated.

Specified by:

getDuplicateProperty in interface Message