public interface ICoreMessage extends Message
BYTES_TYPE, DEFAULT_TYPE, HDR_ACTUAL_EXPIRY_TIME, HDR_BRIDGE_DUPLICATE_ID, HDR_CONTENT_TYPE, HDR_DUPLICATE_DETECTION_ID, HDR_GROUP_ID, HDR_LARGE_BODY_SIZE, HDR_LARGE_COMPRESSED, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_ADDRESS, HDR_ORIGINAL_QUEUE, HDR_ROUTE_TO_ACK_IDS, HDR_ROUTE_TO_IDS, HDR_ROUTING_TYPE, HDR_SCALEDOWN_TO_IDS, HDR_SCHEDULED_DELIVERY_TIME, HDR_VALIDATED_USER, MAP_TYPE, memoryOffset, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE
Modifier and Type | Method and Description |
---|---|
void |
copyHeadersAndProperties(Message msg)
Used on large messages treatment
|
ActiveMQBuffer |
getBodyBuffer()
The body used for this message.
|
org.apache.activemq.artemis.core.message.LargeBodyEncoder |
getBodyEncoder() |
InputStream |
getBodyInputStream() |
int |
getEndOfBodyPosition() |
int |
getHeadersAndPropertiesEncodeSize() |
ActiveMQBuffer |
getReadOnlyBodyBuffer()
Returns a new Buffer slicing the current Body.
|
byte |
getType()
Return the type of the message
|
boolean |
isServerMessage()
We are really interested if this is a LargeServerMessage.
|
org.apache.activemq.artemis.core.message.impl.CoreMessage |
setType(byte type)
the type of the message
|
default Map<String,Object> |
toMap() |
acceptsConsumer, cleanupInternalProperties, containsProperty, containsProperty, copy, copy, decrementDurableRefCount, decrementRefCount, getAddress, getAddressSimpleString, getAnnotation, getAnnotationString, getBooleanProperty, getBooleanProperty, getBuffer, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getConnectionID, getContext, getDoubleProperty, getDoubleProperty, getDuplicateIDBytes, getDuplicateProperty, getEncodeSize, getExpiration, getFloatProperty, getFloatProperty, getGroupID, getIntProperty, getIntProperty, getLastValueProperty, getLongProperty, getLongProperty, getMemoryEstimate, getMessageID, getObjectProperty, getObjectProperty, getPersister, getPersistSize, getPriority, getPropertyNames, getRefCount, getReplyTo, getRoutingType, getScheduledDeliveryTime, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getUserID, incrementDurableRefCount, incrementRefCount, isDurable, isExpired, isLargeMessage, messageChanged, persist, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putCharProperty, putCharProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, receiveBuffer, reencode, referenceOriginalMessage, rejectConsumer, releaseBuffer, reloadPersistence, removeAnnotation, removeProperty, removeProperty, sendBuffer, setAddress, setAddress, setAnnotation, setBuffer, setConnectionID, setContext, setDurable, setExpiration, setMessageID, setPriority, setReplyTo, setRoutingType, setScheduledDeliveryTime, setTimestamp, setUserID, toCore, toPropertyMap
org.apache.activemq.artemis.core.message.LargeBodyEncoder getBodyEncoder() throws ActiveMQException
ActiveMQException
int getHeadersAndPropertiesEncodeSize()
InputStream getBodyInputStream()
getBodyInputStream
in interface Message
ActiveMQBuffer getReadOnlyBodyBuffer()
org.apache.activemq.artemis.core.message.impl.CoreMessage setType(byte type)
boolean isServerMessage()
ActiveMQBuffer getBodyBuffer()
getBodyBuffer
in interface Message
int getEndOfBodyPosition()
void copyHeadersAndProperties(Message msg)
Copyright © 2017 The Apache Software Foundation. All rights reserved.