org.openspaces.esb.mule.queue

Class OpenSpacesQueueObject

java.lang.Object

org.openspaces.esb.mule.queue.OpenSpacesQueueObject

Direct Known Subclasses:

OpenSpacesFifoQueueObject

public class OpenSpacesQueueObject
extends Object

An internal queue entry holding the endpoint address and the queue payload. The payload can be serialized when written to space, to avoid class loading issues on space side.

Author:

anna

Field Summary

Fields

Modifier and Type	Field and Description
static String	RESPONSE_TIMEOUT_PROPERTY

Constructor Summary

Constructors

Constructor and Description
OpenSpacesQueueObject()

Method Summary

Modifier and Type	Method and Description
String	getCorrelationID()
String	getEndpointURI()
String	getId()
Object	getInternalPayload() For internal usage only, to get the payload use getPayload() method.
Object	getPayload()
DocumentProperties	getPayloadMetaData()
boolean	getPersistent()
void	setCorrelationID(String correlationID)
void	setEndpointURI(String endpointURI)
void	setId(String id)
void	setInternalPayload(Object payload) For internal usage only, to set the payload use setPayload(Object payload) method.
void	setPayload(Object payload)
void	setPayloadMetaData(DocumentProperties payloadMetaData)
void	setPersistent(boolean isPersistent)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

RESPONSE_TIMEOUT_PROPERTY

public static final String RESPONSE_TIMEOUT_PROPERTY

See Also:

Constant Field Values

Constructor Detail

OpenSpacesQueueObject

public OpenSpacesQueueObject()

Method Detail

getId

public String getId()

setId

public void setId(String id)

setEndpointURI

public void setEndpointURI(String endpointURI)

getEndpointURI

public String getEndpointURI()

getPayload

public Object getPayload()
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

setPayload

public void setPayload(Object payload)
                throws IOException

Throws:

IOException

getInternalPayload

public Object getInternalPayload()

For internal usage only, to get the payload use getPayload() method.

Returns:

internalPayload

setInternalPayload

public void setInternalPayload(Object payload)

For internal usage only, to set the payload use setPayload(Object payload) method.

getPayloadMetaData

public DocumentProperties getPayloadMetaData()

setPayloadMetaData

public void setPayloadMetaData(DocumentProperties payloadMetaData)

getCorrelationID

public String getCorrelationID()

setCorrelationID

public void setCorrelationID(String correlationID)

getPersistent

public boolean getPersistent()

setPersistent

public void setPersistent(boolean isPersistent)

toString

public String toString()

Overrides:

toString in class Object