org.jboss.messaging.core.server.impl
Class ServerMessageImpl
java.lang.Object
org.jboss.messaging.core.message.impl.MessageImpl
org.jboss.messaging.core.server.impl.ServerMessageImpl
- All Implemented Interfaces:
- EncodingSupport, Message, ServerMessage
- Direct Known Subclasses:
- JournalLargeServerMessage, NullStorageLargeServerMessage
public class ServerMessageImpl
- extends MessageImpl
- implements ServerMessage
A ServerMessageImpl
- Author:
- Tim Fox, Andy Taylor, Clebert Suconic
Fields inherited from class org.jboss.messaging.core.message.impl.MessageImpl |
durable, HDR_ACTUAL_EXPIRY_TIME, HDR_DUPLICATE_DETECTION_ID, HDR_FROM_CLUSTER, HDR_GROUP_ID, HDR_LAST_VALUE_NAME, HDR_ORIG_MESSAGE_ID, HDR_ORIGINAL_DESTINATION, HDR_ROUTE_TO_IDS, HDR_SCHEDULED_DELIVERY_TIME, messageID, type |
Methods inherited from class org.jboss.messaging.core.message.impl.MessageImpl |
containsProperty, containsProperty, decode, decodeBody, decodeProperties, encode, encodeBody, encodeBody, encodeProperties, getBody, getBodyInputStream, getBodySize, getDestination, getEncodeSize, getExpiration, getMessageID, getPriority, getProperties, getPropertiesEncodeSize, getProperty, getProperty, getPropertyNames, getTimestamp, getType, isDurable, isExpired, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, putTypedProperties, removeProperty, removeProperty, setBody, setBodyInputStream, setDestination, setDurable, setExpiration, setPriority, setTimestamp, toMap |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.jboss.messaging.core.message.Message |
containsProperty, containsProperty, decode, decodeBody, decodeProperties, encode, encodeBody, encodeBody, encodeProperties, getBody, getBodyInputStream, getBodySize, getDestination, getEncodeSize, getExpiration, getMessageID, getPriority, getProperties, getPropertiesEncodeSize, getProperty, getProperty, getPropertyNames, getTimestamp, getType, isDurable, isExpired, putBooleanProperty, putBooleanProperty, putByteProperty, putByteProperty, putBytesProperty, putBytesProperty, putDoubleProperty, putDoubleProperty, putFloatProperty, putFloatProperty, putIntProperty, putIntProperty, putLongProperty, putLongProperty, putShortProperty, putShortProperty, putStringProperty, putStringProperty, putTypedProperties, removeProperty, removeProperty, setBody, setBodyInputStream, setDestination, setDurable, setExpiration, setPriority, setTimestamp, toMap |
ServerMessageImpl
public ServerMessageImpl()
ServerMessageImpl
public ServerMessageImpl(long messageID)
ServerMessageImpl
public ServerMessageImpl(ServerMessageImpl other)
ServerMessageImpl
public ServerMessageImpl(ServerMessage other)
ServerMessageImpl
public ServerMessageImpl(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority,
MessagingBuffer buffer)
- Only used in testing
setMessageID
public void setMessageID(long id)
- Specified by:
setMessageID
in interface ServerMessage
setType
public void setType(byte type)
createReference
public MessageReference createReference(Queue queue)
- Specified by:
createReference
in interface ServerMessage
isStored
public boolean isStored()
- Specified by:
isStored
in interface ServerMessage
setStored
public void setStored()
- Specified by:
setStored
in interface ServerMessage
incrementRefCount
public int incrementRefCount()
- Specified by:
incrementRefCount
in interface ServerMessage
incrementDurableRefCount
public int incrementDurableRefCount()
- Specified by:
incrementDurableRefCount
in interface ServerMessage
decrementDurableRefCount
public int decrementDurableRefCount()
- Specified by:
decrementDurableRefCount
in interface ServerMessage
decrementRefCount
public int decrementRefCount()
- Specified by:
decrementRefCount
in interface ServerMessage
getRefCount
public int getRefCount()
- Specified by:
getRefCount
in interface ServerMessage
isLargeMessage
public boolean isLargeMessage()
- Specified by:
isLargeMessage
in interface Message
getLargeBodySize
public long getLargeBodySize()
- Specified by:
getLargeBodySize
in interface Message
getMemoryEstimate
public int getMemoryEstimate()
- Specified by:
getMemoryEstimate
in interface ServerMessage
copy
public ServerMessage copy(long newID)
throws java.lang.Exception
- Specified by:
copy
in interface ServerMessage
- Throws:
java.lang.Exception
copy
public ServerMessage copy()
throws java.lang.Exception
- Specified by:
copy
in interface ServerMessage
- Throws:
java.lang.Exception
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
Copyright © 2006 JBoss Inc. All Rights Reserved.