public abstract class Message extends BaseCommand implements MarshallAware
Modifier and Type | Field and Description |
---|---|
protected long |
arrival |
protected long |
brokerInTime |
protected long |
brokerOutTime |
protected CachedEncodingTrait |
cachedEncoding |
protected boolean |
compressed |
protected org.fusesource.hawtbuf.Buffer |
content |
protected org.fusesource.hawtbuf.UTF8Buffer |
correlationId |
protected DataStructure |
dataStructure |
static int |
DEFAULT_MINIMUM_MESSAGE_SIZE
The default minimum amount of memory a message is assumed to use
|
protected ActiveMQDestination |
destination |
protected boolean |
droppable |
protected int |
encodedSize |
protected long |
expiration |
protected org.fusesource.hawtbuf.UTF8Buffer |
groupID |
protected int |
groupSequence |
protected org.fusesource.hawtbuf.Buffer |
marshalledProperties |
protected MessageId |
messageId |
protected ActiveMQDestination |
originalDestination |
protected TransactionId |
originalTransactionId |
protected boolean |
persistent |
protected byte |
priority |
protected ProducerId |
producerId |
protected java.util.Map<java.lang.String,java.lang.Object> |
properties |
protected boolean |
readOnlyBody |
protected boolean |
readOnlyProperties |
protected boolean |
recievedByDFBridge |
protected int |
redeliveryCounter |
protected ActiveMQDestination |
replyTo |
protected int |
size |
protected ConsumerId |
targetConsumerId |
protected long |
timestamp |
protected TransactionId |
transactionId |
protected org.fusesource.hawtbuf.UTF8Buffer |
type |
protected org.fusesource.hawtbuf.UTF8Buffer |
userID |
commandId, responseRequired
Constructor and Description |
---|
Message() |
Modifier and Type | Method and Description |
---|---|
void |
afterMarshall(OpenWireFormat wireFormat) |
void |
afterUnmarshall(OpenWireFormat wireFormat) |
void |
beforeMarshall(OpenWireFormat wireFormat) |
void |
beforeUnmarshall(OpenWireFormat wireFormat) |
abstract void |
clearBody() |
void |
clearMarshalledState() |
void |
clearProperties() |
abstract Message |
copy() |
protected void |
copy(Message copy) |
int |
decrementReferenceCount() |
long |
getArrival()
Used to schedule the arrival time of a message to a broker.
|
long |
getBrokerInTime() |
long |
getBrokerOutTime() |
BrokerId[] |
getBrokerPath()
The route of brokers the command has moved through.
|
CachedEncodingTrait |
getCachedEncoding() |
BrokerId[] |
getCluster()
If a message is stored in multiple nodes on a cluster, all the cluster
members will be listed here.
|
org.fusesource.hawtbuf.Buffer |
getContent() |
org.fusesource.hawtbuf.UTF8Buffer |
getCorrelationId() |
DataStructure |
getDataStructure() |
ActiveMQDestination |
getDestination() |
int |
getEncodedSize() |
long |
getExpiration() |
org.fusesource.hawtbuf.UTF8Buffer |
getGroupID() |
int |
getGroupSequence() |
org.fusesource.hawtbuf.Buffer |
getMarshalledProperties() |
Message |
getMessage() |
Message |
getMessageHardRef() |
MessageId |
getMessageId() |
protected int |
getMinimumMessageSize() |
ActiveMQDestination |
getOriginalDestination() |
TransactionId |
getOriginalTransactionId() |
byte |
getPriority() |
ProducerId |
getProducerId() |
java.util.Map<java.lang.String,java.lang.Object> |
getProperties() |
java.lang.Object |
getProperty(java.lang.String name) |
int |
getRedeliveryCounter() |
int |
getReferenceCount() |
ActiveMQDestination |
getReplyTo() |
int |
getSize() |
ConsumerId |
getTargetConsumerId()
Can be used to route the message to a specific consumer.
|
long |
getTimestamp() |
TransactionId |
getTransactionId() |
org.fusesource.hawtbuf.UTF8Buffer |
getType() |
org.fusesource.hawtbuf.UTF8Buffer |
getUserID()
Only set by the broker and defines the userID of the producer connection
who sent this message.
|
void |
incrementRedeliveryCounter() |
int |
incrementReferenceCount() |
boolean |
isAdvisory() |
boolean |
isCompressed() |
boolean |
isDroppable() |
boolean |
isDropped() |
boolean |
isExpired() |
boolean |
isInTransaction() |
boolean |
isMarshallAware() |
boolean |
isMessage() |
boolean |
isPersistent() |
boolean |
isReadOnlyBody() |
boolean |
isReadOnlyProperties() |
boolean |
isRecievedByDFBridge() |
boolean |
isRedelivered() |
protected void |
lazyCreateProperties() |
void |
onMessageRolledBack() |
void |
setArrival(long arrival) |
void |
setBrokerInTime(long brokerInTime) |
void |
setBrokerOutTime(long brokerOutTime) |
void |
setBrokerPath(BrokerId[] brokerPath) |
void |
setCachedEncoding(CachedEncodingTrait cachedEncoding) |
void |
setCluster(BrokerId[] cluster) |
void |
setCompressed(boolean compressed) |
void |
setContent(org.fusesource.hawtbuf.Buffer content) |
void |
setCorrelationId(org.fusesource.hawtbuf.UTF8Buffer correlationId) |
void |
setDataStructure(DataStructure data) |
void |
setDestination(ActiveMQDestination destination) |
void |
setDroppable(boolean droppable) |
void |
setEncodedSize(int encodedSize) |
void |
setExpiration(long expiration) |
void |
setGroupID(org.fusesource.hawtbuf.UTF8Buffer groupID) |
void |
setGroupSequence(int groupSequence) |
void |
setMarshalledProperties(org.fusesource.hawtbuf.Buffer marshalledProperties) |
void |
setMessageId(MessageId messageId) |
void |
setOriginalDestination(ActiveMQDestination destination) |
void |
setOriginalTransactionId(TransactionId transactionId) |
void |
setPersistent(boolean deliveryMode) |
void |
setPriority(byte priority) |
void |
setProducerId(ProducerId producerId) |
void |
setProperty(java.lang.String name,
java.lang.Object value) |
void |
setReadOnlyBody(boolean readOnlyBody) |
void |
setReadOnlyProperties(boolean readOnlyProperties) |
void |
setRecievedByDFBridge(boolean recievedByDFBridge) |
void |
setRedelivered(boolean redelivered) |
void |
setRedeliveryCounter(int deliveryCounter) |
void |
setReplyTo(ActiveMQDestination replyTo) |
void |
setTargetConsumerId(ConsumerId targetConsumerId) |
void |
setTimestamp(long timestamp) |
void |
setTransactionId(TransactionId transactionId) |
void |
setType(org.fusesource.hawtbuf.UTF8Buffer type) |
void |
setUserID(org.fusesource.hawtbuf.UTF8Buffer jmsxUserID) |
java.lang.String |
toString() |
java.lang.String |
toString(java.util.Map<java.lang.String,java.lang.Object> overrideFields) |
copy, getCommandId, isBrokerInfo, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setResponseRequired
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getDataStructureType
public static final int DEFAULT_MINIMUM_MESSAGE_SIZE
protected MessageId messageId
protected ActiveMQDestination originalDestination
protected TransactionId originalTransactionId
protected ProducerId producerId
protected ActiveMQDestination destination
protected TransactionId transactionId
protected long expiration
protected long timestamp
protected long arrival
protected long brokerInTime
protected long brokerOutTime
protected org.fusesource.hawtbuf.UTF8Buffer correlationId
protected ActiveMQDestination replyTo
protected boolean persistent
protected org.fusesource.hawtbuf.UTF8Buffer type
protected byte priority
protected org.fusesource.hawtbuf.UTF8Buffer groupID
protected int groupSequence
protected ConsumerId targetConsumerId
protected boolean compressed
protected org.fusesource.hawtbuf.UTF8Buffer userID
protected org.fusesource.hawtbuf.Buffer content
protected org.fusesource.hawtbuf.Buffer marshalledProperties
protected DataStructure dataStructure
protected int redeliveryCounter
protected int size
protected java.util.Map<java.lang.String,java.lang.Object> properties
protected boolean readOnlyProperties
protected boolean readOnlyBody
protected transient boolean recievedByDFBridge
protected boolean droppable
protected int encodedSize
protected CachedEncodingTrait cachedEncoding
public abstract Message copy()
public abstract void clearBody() throws OpenwireException
OpenwireException
public int getEncodedSize()
public void setEncodedSize(int encodedSize)
public CachedEncodingTrait getCachedEncoding()
public void setCachedEncoding(CachedEncodingTrait cachedEncoding)
public void clearMarshalledState()
protected void copy(Message copy)
public java.lang.Object getProperty(java.lang.String name) throws java.io.IOException
java.io.IOException
public java.util.Map<java.lang.String,java.lang.Object> getProperties() throws java.io.IOException
java.io.IOException
public void clearProperties()
public void setProperty(java.lang.String name, java.lang.Object value) throws java.io.IOException
java.io.IOException
protected void lazyCreateProperties() throws java.io.IOException
java.io.IOException
public void beforeMarshall(OpenWireFormat wireFormat) throws java.io.IOException
beforeMarshall
in interface MarshallAware
java.io.IOException
public void afterMarshall(OpenWireFormat wireFormat) throws java.io.IOException
afterMarshall
in interface MarshallAware
java.io.IOException
public void beforeUnmarshall(OpenWireFormat wireFormat) throws java.io.IOException
beforeUnmarshall
in interface MarshallAware
java.io.IOException
public void afterUnmarshall(OpenWireFormat wireFormat) throws java.io.IOException
afterUnmarshall
in interface MarshallAware
java.io.IOException
public ProducerId getProducerId()
public void setProducerId(ProducerId producerId)
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
public TransactionId getTransactionId()
public void setTransactionId(TransactionId transactionId)
public boolean isInTransaction()
public ActiveMQDestination getOriginalDestination()
public void setOriginalDestination(ActiveMQDestination destination)
public MessageId getMessageId()
public void setMessageId(MessageId messageId)
public TransactionId getOriginalTransactionId()
public void setOriginalTransactionId(TransactionId transactionId)
public org.fusesource.hawtbuf.UTF8Buffer getGroupID()
public void setGroupID(org.fusesource.hawtbuf.UTF8Buffer groupID)
public int getGroupSequence()
public void setGroupSequence(int groupSequence)
public org.fusesource.hawtbuf.UTF8Buffer getCorrelationId()
public void setCorrelationId(org.fusesource.hawtbuf.UTF8Buffer correlationId)
public boolean isPersistent()
public void setPersistent(boolean deliveryMode)
public long getExpiration()
public void setExpiration(long expiration)
public byte getPriority()
public void setPriority(byte priority)
public ActiveMQDestination getReplyTo()
public void setReplyTo(ActiveMQDestination replyTo)
public long getTimestamp()
public void setTimestamp(long timestamp)
public org.fusesource.hawtbuf.UTF8Buffer getType()
public void setType(org.fusesource.hawtbuf.UTF8Buffer type)
public org.fusesource.hawtbuf.Buffer getContent()
public void setContent(org.fusesource.hawtbuf.Buffer content)
public org.fusesource.hawtbuf.Buffer getMarshalledProperties()
public void setMarshalledProperties(org.fusesource.hawtbuf.Buffer marshalledProperties)
public DataStructure getDataStructure()
public void setDataStructure(DataStructure data)
public ConsumerId getTargetConsumerId()
public void setTargetConsumerId(ConsumerId targetConsumerId)
public boolean isExpired()
public boolean isAdvisory()
public boolean isCompressed()
public void setCompressed(boolean compressed)
public boolean isRedelivered()
public void setRedelivered(boolean redelivered)
public void incrementRedeliveryCounter()
public int getRedeliveryCounter()
public void setRedeliveryCounter(int deliveryCounter)
public BrokerId[] getBrokerPath()
public void setBrokerPath(BrokerId[] brokerPath)
public boolean isReadOnlyProperties()
public void setReadOnlyProperties(boolean readOnlyProperties)
public boolean isReadOnlyBody()
public void setReadOnlyBody(boolean readOnlyBody)
public long getArrival()
public void setArrival(long arrival)
public org.fusesource.hawtbuf.UTF8Buffer getUserID()
public void setUserID(org.fusesource.hawtbuf.UTF8Buffer jmsxUserID)
public int getReferenceCount()
public Message getMessageHardRef()
public Message getMessage() throws java.io.IOException
java.io.IOException
public boolean isMarshallAware()
isMarshallAware
in interface DataStructure
isMarshallAware
in class BaseCommand
public int incrementReferenceCount()
public int decrementReferenceCount()
public int getSize()
protected int getMinimumMessageSize()
public boolean isRecievedByDFBridge()
public void setRecievedByDFBridge(boolean recievedByDFBridge)
recievedByDFBridge
- The recievedByDFBridge to set.public void onMessageRolledBack()
public boolean isDroppable()
public void setDroppable(boolean droppable)
public BrokerId[] getCluster()
public void setCluster(BrokerId[] cluster)
public boolean isMessage()
isMessage
in interface Command
isMessage
in class BaseCommand
public long getBrokerInTime()
public void setBrokerInTime(long brokerInTime)
public long getBrokerOutTime()
public void setBrokerOutTime(long brokerOutTime)
public boolean isDropped()
public java.lang.String toString()
toString
in class BaseCommand
public java.lang.String toString(java.util.Map<java.lang.String,java.lang.Object> overrideFields)
toString
in class BaseCommand
Copyright © 2011-2014 Red Hat. All Rights Reserved.