public class ActiveMQObjectMessage extends ActiveMQMessage
Modifier and Type | Field and Description |
---|---|
static byte |
DATA_STRUCTURE_TYPE |
protected java.io.Serializable |
object |
arrival, brokerInTime, brokerOutTime, cachedEncoding, compressed, content, correlationId, dataStructure, DEFAULT_MINIMUM_MESSAGE_SIZE, destination, droppable, encodedSize, expiration, groupID, groupSequence, marshalledProperties, messageId, originalDestination, originalTransactionId, persistent, priority, producerId, properties, readOnlyBody, readOnlyProperties, recievedByDFBridge, redeliveryCounter, replyTo, size, targetConsumerId, timestamp, transactionId, type, userID
commandId, responseRequired
Constructor and Description |
---|
ActiveMQObjectMessage() |
Modifier and Type | Method and Description |
---|---|
void |
beforeMarshall(OpenWireFormat wireFormat) |
void |
clearBody() |
void |
clearMarshalledState() |
Message |
copy() |
byte |
getDataStructureType() |
java.lang.String |
getJMSXMimeType() |
java.io.Serializable |
getObject()
Gets the serializable object containing this message's data.
|
void |
onMessageRolledBack() |
void |
setObject(java.io.Serializable newObject) |
void |
storeContent() |
java.lang.String |
toString() |
checkReadOnlyBody, checkValidObject, clearProperties, copy, equals, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hashCode, isExpired, onSend, propertyExists, setBooleanProperty, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setObjectProperty, setShortProperty, setStringProperty
afterMarshall, afterUnmarshall, beforeUnmarshall, copy, decrementReferenceCount, getArrival, getBrokerInTime, getBrokerOutTime, getBrokerPath, getCachedEncoding, getCluster, getContent, getCorrelationId, getDataStructure, getDestination, getEncodedSize, getExpiration, getGroupID, getGroupSequence, getMarshalledProperties, getMessage, getMessageHardRef, getMessageId, getMinimumMessageSize, getOriginalDestination, getOriginalTransactionId, getPriority, getProducerId, getProperties, getProperty, getRedeliveryCounter, getReferenceCount, getReplyTo, getSize, getTargetConsumerId, getTimestamp, getTransactionId, getType, getUserID, incrementRedeliveryCounter, incrementReferenceCount, isAdvisory, isCompressed, isDroppable, isDropped, isInTransaction, isMarshallAware, isMessage, isPersistent, isReadOnlyBody, isReadOnlyProperties, isRecievedByDFBridge, isRedelivered, lazyCreateProperties, setArrival, setBrokerInTime, setBrokerOutTime, setBrokerPath, setCachedEncoding, setCluster, setCompressed, setContent, setCorrelationId, setDataStructure, setDestination, setDroppable, setEncodedSize, setExpiration, setGroupID, setGroupSequence, setMarshalledProperties, setMessageId, setOriginalDestination, setOriginalTransactionId, setPersistent, setPriority, setProducerId, setProperty, setReadOnlyBody, setReadOnlyProperties, setRecievedByDFBridge, setRedelivered, setRedeliveryCounter, setReplyTo, setTargetConsumerId, setTimestamp, setTransactionId, setType, setUserID, toString
copy, getCommandId, isBrokerInfo, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setResponseRequired
public static final byte DATA_STRUCTURE_TYPE
protected transient java.io.Serializable object
public Message copy()
copy
in class ActiveMQMessage
public void beforeMarshall(OpenWireFormat wireFormat) throws java.io.IOException
beforeMarshall
in interface MarshallAware
beforeMarshall
in class Message
java.io.IOException
public void storeContent()
public byte getDataStructureType()
getDataStructureType
in interface DataStructure
getDataStructureType
in class ActiveMQMessage
public java.lang.String getJMSXMimeType()
public void clearBody() throws OpenwireException
clearBody
in class ActiveMQMessage
OpenwireException
public void setObject(java.io.Serializable newObject) throws OpenwireException
OpenwireException
public java.io.Serializable getObject() throws OpenwireException
OpenwireException
public void clearMarshalledState()
clearMarshalledState
in class Message
public void onMessageRolledBack()
onMessageRolledBack
in class Message
Copyright © 2011-2014 Red Hat. All Rights Reserved.