public interface ICoreMessage extends 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, MAP_TYPE, memoryOffset, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE
Modifier and Type | Method and Description |
---|---|
void |
copyHeadersAndProperties(Message msg)
Used on large messages treatment
|
org.apache.activemq.artemis.api.core.ActiveMQBuffer |
getBodyBuffer()
The body used for this message.
|
int |
getBodyBufferSize()
Returns the length in bytes of the body buffer.
|
org.apache.activemq.artemis.core.message.LargeBodyEncoder |
getBodyEncoder() |
InputStream |
getBodyInputStream() |
org.apache.activemq.artemis.api.core.ActiveMQBuffer |
getDataBuffer()
Returns a readOnlyBodyBuffer or a decompressed one if the message is compressed.
|
int |
getEndOfBodyPosition() |
int |
getHeadersAndPropertiesEncodeSize() |
org.apache.activemq.artemis.api.core.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.
|
void |
receiveBuffer_1X(io.netty.buffer.ByteBuf buffer)
it will fix the body of incoming messages from 1.x and before versions
|
void |
sendBuffer_1X(io.netty.buffer.ByteBuf sendBuffer) |
org.apache.activemq.artemis.core.message.impl.CoreMessage |
setType(byte type)
the type of the message
|
default Map<String,Object> |
toMap() |
acceptsConsumer, clearInternalProperties, containsProperty, containsProperty, copy, copy, decrementDurableRefCount, decrementRefCount, getAddress, getAddressSimpleString, getAnnotation, getAnnotationString, getBooleanProperty, getBooleanProperty, getBuffer, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getConnectionID, getContext, getCorrelationID, getDoubleProperty, getDoubleProperty, getDuplicateIDBytes, getDuplicateProperty, getEncodeSize, getExpiration, getExtraBytesProperty, getFloatProperty, getFloatProperty, getGroupID, getGroupSequence, getIntProperty, getIntProperty, getLastValueProperty, getLongProperty, getLongProperty, getMemoryEstimate, getMessageID, getObjectProperty, getObjectProperty, getPersistentSize, getPersister, getPersistSize, getPriority, getPropertyNames, getRefCount, getReplyTo, getRoutingType, getScheduledDeliveryTime, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getUserID, getValidatedUserID, incrementDurableRefCount, incrementRefCount, 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, setBuffer, setConnectionID, setContext, setCorrelationID, setDurable, setExpiration, setGroupID, setGroupID, setGroupSequence, setLastValueProperty, setMessageID, setPriority, setReplyTo, setRoutingType, setScheduledDeliveryTime, setTimestamp, setUserID, setValidatedUserID, toCore, toCore, toPropertyMap
org.apache.activemq.artemis.core.message.LargeBodyEncoder getBodyEncoder() throws org.apache.activemq.artemis.api.core.ActiveMQException
org.apache.activemq.artemis.api.core.ActiveMQException
int getHeadersAndPropertiesEncodeSize()
InputStream getBodyInputStream()
getBodyInputStream
in interface Message
org.apache.activemq.artemis.api.core.ActiveMQBuffer getReadOnlyBodyBuffer()
int getBodyBufferSize()
org.apache.activemq.artemis.api.core.ActiveMQBuffer getDataBuffer()
org.apache.activemq.artemis.core.message.impl.CoreMessage setType(byte type)
boolean isServerMessage()
org.apache.activemq.artemis.api.core.ActiveMQBuffer getBodyBuffer()
getBodyBuffer
in interface Message
int getEndOfBodyPosition()
void copyHeadersAndProperties(Message msg)
void sendBuffer_1X(io.netty.buffer.ByteBuf sendBuffer)
void receiveBuffer_1X(io.netty.buffer.ByteBuf buffer)
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.