Class AMQPStandardMessage

java.lang.Object

org.apache.activemq.artemis.api.core.RefCountMessage

org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage

org.apache.activemq.artemis.protocol.amqp.broker.AMQPStandardMessage

All Implemented Interfaces:

Message

public class AMQPStandardMessage
extends AMQPMessage

Nested Class Summary

Nested classes/interfaces inherited from class AMQPMessage

AMQPMessage.MessageDataScanningStatus

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.qpid.proton.codec.ReadableBuffer	data

Fields inherited from class AMQPMessage

address, ADDRESS_PROPERTY, applicationProperties, applicationPropertiesPosition, connectionID, coreMessageObjectPools, DEFAULT_MESSAGE_FORMAT, DEFAULT_MESSAGE_PRIORITY, deliveryAnnotations, deliveryAnnotationsForSendBuffer, deliveryAnnotationsPosition, encodedDeliveryAnnotationsSize, encodedHeaderSize, expiration, expirationReload, extraProperties, header, headerPosition, isPaged, logger, MAX_MESSAGE_PRIORITY, memoryEstimate, messageAnnotations, messageAnnotationsPosition, messageDataScanned, messageFormat, messageID, modified, originalEstimate, priority, properties, propertiesPosition, rejectedConsumers, remainingBodyPosition, routed, scheduledTime, VALUE_NOT_PRESENT

Fields inherited from interface 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
AMQPStandardMessage(long messageFormat, byte[] data, org.apache.activemq.artemis.utils.collections.TypedProperties extraProperties)	Creates a new AMQPStandardMessage instance from binary encoded message data.
AMQPStandardMessage(long messageFormat, byte[] data, org.apache.activemq.artemis.utils.collections.TypedProperties extraProperties, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools)	Creates a new AMQPStandardMessage instance from binary encoded message data.
AMQPStandardMessage(long messageFormat, org.apache.qpid.proton.codec.ReadableBuffer data, org.apache.activemq.artemis.utils.collections.TypedProperties extraProperties, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools)	Creates a new AMQPStandardMessage instance from binary encoded message data.

Method Summary

Modifier and Type	Method	Description
Message	copy()
final Message	copy(long newID)
static AMQPStandardMessage	createMessage(long messageID, long messageFormat, SimpleString replyTo, org.apache.qpid.proton.amqp.messaging.Header header, org.apache.qpid.proton.amqp.messaging.Properties properties, Map<org.apache.qpid.proton.amqp.Symbol, Object> daMap, Map<org.apache.qpid.proton.amqp.Symbol, Object> maMap, Map<String,Object> apMap, Map<org.apache.qpid.proton.amqp.Symbol, Object> footerMap, org.apache.qpid.proton.amqp.messaging.Section body)
protected void	encodeMessage()
protected void	ensureDataIsValid()
protected org.apache.qpid.proton.codec.ReadableBuffer	getData()
int	getEncodeSize()
int	getMemoryEstimate()
long	getPersistentSize()
org.apache.activemq.artemis.core.persistence.Persister<Message>	getPersister()
int	getPersistSize()
String	getStringBody()
void	persist(ActiveMQBuffer targetRecord)
void	reencode()
void	reloadPersistence(ActiveMQBuffer record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)
String	toString()

Methods inherited from class AMQPMessage

acceptsConsumer, addAnnotationsAsProperties, cachedAddressSimpleString, clearInternalProperties, containsProperty, containsProperty, createDeliveryCopy, createExtraProperties, ensureMessageDataScanned, ensureScanning, getAddress, getAddressSimpleString, getAMQPUserID, getAnnotation, getApplicationProperties, getApplicationPropertiesMap, getBody, getBooleanProperty, getBooleanProperty, getBrokerProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getConnectionID, getCorrelationID, getDataScanningStatus, getDecodedApplicationProperties, getDecodedMessageAnnotations, getDeliveryAnnotations, getDeliveryAnnotationsForSendBufferSize, getDoubleProperty, getDoubleProperty, getDuplicateProperty, getEstimateSavedEncode, getExpiration, getExtraBytesProperty, getExtraProperties, getFloatProperty, getFloatProperty, getFooter, getGroupID, getGroupSequence, getHeader, getIngressTimestamp, getIntProperty, getIntProperty, getLastValueProperty, getLongProperty, getLongProperty, getMessageAnnotation, getMessageAnnotation, getMessageAnnotations, getMessageAnnotationsMap, getMessageFormat, getMessageID, getObjectProperty, getObjectProperty, getObjectPropertyForFilter, getOriginalEstimate, getOwner, getPriority, getProperties, getPropertyKeysPool, getPropertyNames, getPropertyValuesPool, getProtocolName, getProtonMessage, getReplyTo, getRoutingType, getScheduledDeliveryTime, getSendBuffer, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getSubject, getTimestamp, getUserID, hasScheduledDeliveryTime, internalPersistSize, isDurable, isPaged, lazyDecodeApplicationProperties, lazyDecodeApplicationProperties, lazyScanAfterReloadPersistence, messageChanged, 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, rejectConsumer, reloadExpiration, removeAnnotation, removeExtraBytesProperty, removeMessageAnnotation, removeProperty, removeProperty, resetMessageData, routed, scanForMessageSection, scanForMessageSection, scanMessageData, scanMessageData, sendBuffer, setAddress, setAddress, setAnnotation, setBrokerProperty, setConnectionID, setCorrelationID, setDeliveryAnnotationsForSendBuffer, setDurable, setExpiration, setExtraProperties, setIngressTimestamp, setLastValueProperty, setMessageAnnotation, setMessageAnnotation, setMessageAnnotations, setMessageID, setOwner, setPaged, setPriority, setReplyTo, setRoutingType, setScheduledDeliveryTime, setTimestamp, setUserID, toCompositeData, toCore, toCore, toDebugString, toPropertyMap, unmarshalledApplicationPropertiesMemoryEstimateFromData, writeDeliveryAnnotationsForSendBuffer

Methods inherited from class RefCountMessage

counterString, debugLocations, deferredDebug, deferredDebug, deferredDebug, disableErrorCheck, durableDown, durableUp, getDurableCount, getParentRef, getRefCount, getUsage, getUserContext, isRefDebugEnabled, isRefTraceEnabled, isReleased, onDown, onUp, refDown, refUp, registerDebug, releaseComplete, released, setParentRef, setUserContext, usageDown, usageUp

Methods inherited from class Object

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

Methods inherited from interface Message

clearAMQPProperties, copy, durableDown, durableUp, getAnnotationString, getBodyBuffer, getBodyInputStream, getDuplicateIDBytes, getDurableCount, getRefCount, getType, getUsage, getUserContext, getValidatedUserID, getWholeMessageSize, isExpired, isLargeMessage, refDown, referenceOriginalMessage, refUp, setGroupID, setGroupID, setGroupSequence, setType, setUserContext, setValidatedUserID, toMap, toMap, toPropertyMap, usageDown, usageUp

Field Details

data

protected org.apache.qpid.proton.codec.ReadableBuffer data

Constructor Details

AMQPStandardMessage

public AMQPStandardMessage(long messageFormat,
 byte[] data,
 org.apache.activemq.artemis.utils.collections.TypedProperties extraProperties)

Creates a new AMQPStandardMessage instance from binary encoded message data.

Parameters:

messageFormat - The Message format tag given the in Transfer that carried this message

data - The encoded AMQP message

extraProperties - Broker specific extra properties that should be carried with this message

AMQPStandardMessage

public AMQPStandardMessage(long messageFormat,
 byte[] data,
 org.apache.activemq.artemis.utils.collections.TypedProperties extraProperties,
 org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools)

Creates a new AMQPStandardMessage instance from binary encoded message data.

Parameters:

messageFormat - The Message format tag given the in Transfer that carried this message

data - The encoded AMQP message

extraProperties - Broker specific extra properties that should be carried with this message

coreMessageObjectPools - Object pool used to accelerate some String operations.

AMQPStandardMessage

public AMQPStandardMessage(long messageFormat,
 org.apache.qpid.proton.codec.ReadableBuffer data,
 org.apache.activemq.artemis.utils.collections.TypedProperties extraProperties,
 org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools)

Creates a new AMQPStandardMessage instance from binary encoded message data.

Parameters:

messageFormat - The Message format tag given the in Transfer that carried this message

data - The encoded AMQP message in an ReadableBuffer wrapper.

extraProperties - Broker specific extra properties that should be carried with this message

coreMessageObjectPools - Object pool used to accelerate some String operations.

Method Details

createMessage

public static AMQPStandardMessage createMessage(long messageID,
 long messageFormat,
 SimpleString replyTo,
 org.apache.qpid.proton.amqp.messaging.Header header,
 org.apache.qpid.proton.amqp.messaging.Properties properties,
 Map<org.apache.qpid.proton.amqp.Symbol, Object> daMap,
 Map<org.apache.qpid.proton.amqp.Symbol, Object> maMap,
 Map<String,Object> apMap,
 Map<org.apache.qpid.proton.amqp.Symbol, Object> footerMap,
 org.apache.qpid.proton.amqp.messaging.Section body)

copy

public Message copy()

Specified by:

copy in interface Message

Specified by:

copy in class AMQPMessage

getEncodeSize

public int getEncodeSize()

Specified by:

getEncodeSize in interface Message

Specified by:

getEncodeSize in class AMQPMessage

getData

protected org.apache.qpid.proton.codec.ReadableBuffer getData()

Specified by:

getData in class AMQPMessage

getMemoryEstimate

public int getMemoryEstimate()

Specified by:

getMemoryEstimate in interface Message

Specified by:

getMemoryEstimate in class AMQPMessage

persist

public void persist(ActiveMQBuffer targetRecord)

Specified by:

persist in interface Message

Specified by:

persist in class AMQPMessage

copy

public final Message copy(long newID)

getPersistSize

public int getPersistSize()

Specified by:

getPersistSize in interface Message

Specified by:

getPersistSize in class AMQPMessage

reloadPersistence

public void reloadPersistence(ActiveMQBuffer record,
 org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)

Specified by:

reloadPersistence in interface Message

Specified by:

reloadPersistence in class AMQPMessage

getPersistentSize

public long getPersistentSize()
                       throws ActiveMQException

Specified by:

getPersistentSize in interface Message

Specified by:

getPersistentSize in class AMQPMessage

Throws:

ActiveMQException

getPersister

public org.apache.activemq.artemis.core.persistence.Persister<Message> getPersister()

Specified by:

getPersister in interface Message

Specified by:

getPersister in class AMQPMessage

reencode

public void reencode()

Specified by:

reencode in interface Message

Specified by:

reencode in class AMQPMessage

ensureDataIsValid

protected void ensureDataIsValid()

Specified by:

ensureDataIsValid in class AMQPMessage

encodeMessage

protected void encodeMessage()

Specified by:

encodeMessage in class AMQPMessage

toString

public String toString()

Overrides:

toString in class AMQPMessage

getStringBody

public String getStringBody()