org.hornetq.core.server.impl

Class ServerMessageImpl

java.lang.Object

org.hornetq.core.message.impl.MessageImpl

org.hornetq.core.server.impl.ServerMessageImpl

All Implemented Interfaces:

Message, EncodingSupport, MessageInternal, ServerMessage

Direct Known Subclasses:

LargeServerMessageImpl, NullStorageLargeServerMessage

public class ServerMessageImpl
extends MessageImpl
implements ServerMessage

A ServerMessageImpl

Author:

Tim Fox, Andy Taylor, Clebert Suconic

Field Summary

Fields inherited from class org.hornetq.core.message.impl.MessageImpl

address, BODY_OFFSET, bodyBuffer, buffer, BUFFER_HEADER_SPACE, bufferValid, durable, expiration, HDR_BRIDGE_DUPLICATE_ID, HDR_ROUTE_TO_IDS, messageID, priority, properties, timestamp, type

Fields inherited from interface org.hornetq.api.core.Message

BYTES_TYPE, DEFAULT_TYPE, HDR_ACTUAL_EXPIRY_TIME, 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_SCHEDULED_DELIVERY_TIME, MAP_TYPE, OBJECT_TYPE, STREAM_TYPE, TEXT_TYPE

Constructor Summary

Constructors

Modifier	Constructor and Description
	ServerMessageImpl()
	ServerMessageImpl(long messageID, int initialMessageBufferSize)
protected	ServerMessageImpl(ServerMessageImpl other)
protected	ServerMessageImpl(ServerMessageImpl other, TypedProperties properties)

Method Summary

Methods

Modifier and Type	Method and Description
ServerMessage	copy()
ServerMessage	copy(long newID)
MessageReference	createReference(Queue queue)
int	decrementDurableRefCount()
int	decrementRefCount()
void	encodeMessageIDToBuffer()
void	finishCopy()
InputStream	getBodyInputStream()
byte[]	getDuplicateIDBytes()
Object	getDuplicateProperty()
int	getMemoryEstimate()
PagingStore	getPagingStore()
int	getRefCount()
boolean	hasInternalProperties()
int	incrementDurableRefCount()
int	incrementRefCount()
boolean	isLargeMessage() Returns whether this message is a large message or a regular message.
boolean	isServerMessage()
ServerMessage	makeCopyForExpiryOrDLA(long newID, boolean expiry)
void	setMessageID(long id)
void	setOriginalHeaders(ServerMessage other, boolean expiry)
void	setPagingStore(PagingStore pagingStore)
boolean	storeIsPaging()
String	toString()

Methods inherited from class org.hornetq.core.message.impl.MessageImpl

bodyChanged, checkCopy, containsProperty, containsProperty, copyHeadersAndProperties, createBody, decode, decodeFromBuffer, decodeHeadersAndProperties, encode, encodeHeadersAndProperties, getAddress, getBodyBuffer, getBodyEncoder, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodedBuffer, getEncodeSize, getEndOfBodyPosition, getEndOfMessagePosition, getExpiration, getFloatProperty, getFloatProperty, getHeadersAndPropertiesEncodeSize, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPriority, getPropertyNames, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getTypedProperties, getUserID, getWholeBuffer, isDurable, isExpired, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, putTypedProperties, removeProperty, removeProperty, resetCopied, setAddress, setAddressTransient, setDurable, setExpiration, setPriority, setTimestamp, setType, setUserID, toMap

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hornetq.core.message.impl.MessageInternal

bodyChanged, checkCopy, decodeFromBuffer, decodeHeadersAndProperties, encodeHeadersAndProperties, getBodyEncoder, getEncodedBuffer, getEndOfBodyPosition, getEndOfMessagePosition, getHeadersAndPropertiesEncodeSize, getTypedProperties, getWholeBuffer, resetCopied, setAddressTransient

Methods inherited from interface org.hornetq.api.core.Message

containsProperty, containsProperty, getAddress, getBodyBuffer, getBooleanProperty, getBooleanProperty, getByteProperty, getByteProperty, getBytesProperty, getBytesProperty, getDoubleProperty, getDoubleProperty, getEncodeSize, getExpiration, getFloatProperty, getFloatProperty, getIntProperty, getIntProperty, getLongProperty, getLongProperty, getMessageID, getObjectProperty, getObjectProperty, getPriority, getPropertyNames, getShortProperty, getShortProperty, getSimpleStringProperty, getSimpleStringProperty, getStringProperty, getStringProperty, getTimestamp, getType, getUserID, isDurable, isExpired, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putObjectProperty, putObjectProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, removeProperty, removeProperty, setAddress, setDurable, setExpiration, setPriority, setTimestamp, setUserID, toMap

Methods inherited from interface org.hornetq.core.journal.EncodingSupport

decode, encode, getEncodeSize

Constructor Detail

ServerMessageImpl

public ServerMessageImpl()

ServerMessageImpl

public ServerMessageImpl(long messageID,
                 int initialMessageBufferSize)

ServerMessageImpl

protected ServerMessageImpl(ServerMessageImpl other)

ServerMessageImpl

protected ServerMessageImpl(ServerMessageImpl other,
                 TypedProperties properties)

Method Detail

isServerMessage

public boolean isServerMessage()

Specified by:

isServerMessage in interface MessageInternal

setMessageID

public void setMessageID(long id)

Specified by:

setMessageID in interface ServerMessage

createReference

public MessageReference createReference(Queue queue)

Specified by:

createReference in interface ServerMessage

hasInternalProperties

public boolean hasInternalProperties()

Specified by:

hasInternalProperties in interface ServerMessage

incrementRefCount

public int incrementRefCount()
                      throws Exception

Specified by:

incrementRefCount in interface ServerMessage

Throws:

Exception

decrementRefCount

public int decrementRefCount()
                      throws Exception

Specified by:

decrementRefCount in interface ServerMessage

Throws:

Exception

incrementDurableRefCount

public int incrementDurableRefCount()

Specified by:

incrementDurableRefCount in interface ServerMessage

decrementDurableRefCount

public int decrementDurableRefCount()

Specified by:

decrementDurableRefCount in interface ServerMessage

getRefCount

public int getRefCount()

Specified by:

getRefCount in interface ServerMessage

isLargeMessage

public boolean isLargeMessage()

Description copied from interface: Message

Returns whether this message is a large message or a regular message.

Specified by:

isLargeMessage in interface Message

getMemoryEstimate

public int getMemoryEstimate()

Specified by:

getMemoryEstimate in interface ServerMessage

copy

public ServerMessage copy(long newID)

Specified by:

copy in interface ServerMessage

finishCopy

public void finishCopy()
                throws Exception

Specified by:

finishCopy in interface ServerMessage

Throws:

Exception

copy

public ServerMessage copy()

Specified by:

copy in interface ServerMessage

makeCopyForExpiryOrDLA

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

Specified by:

makeCopyForExpiryOrDLA in interface ServerMessage

Throws:

Exception

setOriginalHeaders

public void setOriginalHeaders(ServerMessage other,
                      boolean expiry)

Specified by:

setOriginalHeaders in interface ServerMessage

setPagingStore

public void setPagingStore(PagingStore pagingStore)

Specified by:

setPagingStore in interface ServerMessage

getPagingStore

public PagingStore getPagingStore()

Specified by:

getPagingStore in interface ServerMessage

storeIsPaging

public boolean storeIsPaging()

Specified by:

storeIsPaging in interface ServerMessage

toString

public String toString()

Overrides:

toString in class Object

getBodyInputStream

public InputStream getBodyInputStream()

Specified by:

getBodyInputStream in interface MessageInternal

encodeMessageIDToBuffer

public void encodeMessageIDToBuffer()

Specified by:

encodeMessageIDToBuffer in interface ServerMessage

getDuplicateIDBytes

public byte[] getDuplicateIDBytes()

Specified by:

getDuplicateIDBytes in interface ServerMessage

getDuplicateProperty

public Object getDuplicateProperty()

Specified by:

getDuplicateProperty in interface ServerMessage