public class GSObjectMessageImpl extends GSMessageImpl implements javax.jms.ObjectMessage
javax.jms.ObjectMessage
interface for the GigaSpaces JMS API. An
ObjectMessage
object is used to send a message that contains a serializable object
in the Java programming language ("Java object"). It inherits from the Message
interface and adds a body containing a single reference to an object. Only
Serializable
Java objects can be used.
If a collection of Java objects must be sent, one of the Collection
classes
provided since JDK 1.2 can be used.
When a client receives an ObjectMessage
, it is in read-only mode. If a client
attempts to write to the message at this point, a MessageNotWriteableException
is
thrown. If clearBody
is called, the message can now be both read from and written
to.
Session.createObjectMessage()
,
Session.createObjectMessage(Serializable)
,
Message
,
Serialized FormBody, BODY_STR_NAME, BYTES, DestinationName, indexedFields, JMS_CORRELATION_ID, JMS_DELIVERY_MODE, JMS_DESTINATION, JMS_EXPIRATION, JMS_GSCONNECTION_KEY_NAME, JMS_GSCONVERTER, JMS_GSPRODUCER_KEY_PROP_NAME, JMS_GSTTL_KEY_PROP_NAME, JMS_MESSAGE_ID, JMS_PRIORITY, JMS_REDELIVERED, JMS_REPLY_TO, JMS_TIMESTAMP, JMS_TYPE, JMSCorrelationID, JMSDeliveryMode, JMSDestination, JMSExpiration, JMSMessageID, JMSPriority, JMSRedelivered, JMSReplyTo, JMSTimestamp, JMSType, JMSX_GROUPID, JMSX_GROUPSEQ, JMSX_USERID, MAP, OBJECT, Properties, PROPERTIES_STR_NAME, session, SIMPLE, STREAM, TEXT
Constructor and Description |
---|
GSObjectMessageImpl()
Instantiates a new
GSObjectMessageImpl . |
GSObjectMessageImpl(GSSessionImpl session)
Instantiates a new
GSObjectMessageImpl . |
GSObjectMessageImpl(GSSessionImpl session,
Serializable objBody)
Instantiates a new
GSObjectMessageImpl . |
Modifier and Type | Method and Description |
---|---|
protected Object |
cloneBody()
Returns a clone of the body.
|
Serializable |
getObject()
Get the serializable object containing this message's data.
|
void |
readBody(DataInput dataIn)
Used to help build the body from an input stream
|
void |
setObject(Serializable obj)
Set the serializable object containing this message's data.
|
void |
writeBody(DataOutput dataOut)
Used serialize the message body to an output stream
|
__getSpaceIndexedFields, acknowledge, checkBodyReadOnly, checkBodyWriteOnly, checkPropertiesReadOnly, clearBody, clearProperties, cloneObject, copyTo, equals, getBooleanProperty, getByteProperty, getDestinationName, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hashCode, propertyExists, readExternal, setBooleanProperty, setByteProperty, setDestinationName, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setProperties, setRoutingIndexes, setShortProperty, setStringProperty, toString, writeExternal
__getEntryInfo, __setEntryInfo, _readExternal, _writeExternal, isFifo, isNOWriteLeaseMode, isTransient, makePersistent, makeTransient, setFifo, setNOWriteLeaseMode, setTransient
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
acknowledge, clearBody, clearProperties, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty
public GSObjectMessageImpl() throws javax.jms.JMSException
GSObjectMessageImpl
.javax.jms.JMSException
- if falied to create the messagepublic GSObjectMessageImpl(GSSessionImpl session, Serializable objBody) throws javax.jms.JMSException
GSObjectMessageImpl
.session
- the session of the messageobjBody
- the object content of the messagejavax.jms.JMSException
- if falied to create the messagepublic GSObjectMessageImpl(GSSessionImpl session) throws javax.jms.JMSException
GSObjectMessageImpl
.session
- the session of the messagejavax.jms.JMSException
- if falied to create the messagepublic final void setObject(Serializable obj) throws javax.jms.JMSException
ObjectMessage
contains a snapshot of the object at the time
setObject()
is called - subsequent modifications of the object will have no
affect on the ObjectMessage
body.setObject
in interface javax.jms.ObjectMessage
obj
- the message's datajavax.jms.MessageFormatException
- if object serialization failsMessageNotWriteableException
- if the message is read-onlyjavax.jms.JMSException
public final Serializable getObject() throws javax.jms.MessageFormatException
getObject
in interface javax.jms.ObjectMessage
javax.jms.MessageFormatException
- if object deserialization failspublic void writeBody(DataOutput dataOut) throws IOException
IOException
public void readBody(DataInput dataIn) throws IOException
IOException
protected Object cloneBody()
cloneBody
in class GSMessageImpl
Copyright © GigaSpaces.