org.openspaces.esb.mule.eventcontainer
Class OpenSpacesMessageAdapter

java.lang.Object
  org.mule.transport.AbstractMessageAdapter
      org.openspaces.esb.mule.eventcontainer.OpenSpacesMessageAdapter

All Implemented Interfaces:

Serializable, org.mule.api.ThreadSafeAccess, org.mule.api.transport.MessageAdapter

public class OpenSpacesMessageAdapter
extends org.mule.transport.AbstractMessageAdapter

Author:

yitzhaki

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.mule.api.ThreadSafeAccess

org.mule.api.ThreadSafeAccess.AccessControl

Field Summary

Fields inherited from class org.mule.transport.AbstractMessageAdapter

attachments, exceptionPayload, id, logger, properties

Fields inherited from interface org.mule.api.ThreadSafeAccess

READ, WRITE

Constructor Summary

OpenSpacesMessageAdapter(Object msg)

OpenSpacesMessageAdapter(OpenSpacesMessageAdapter template)

Method Summary

int	getCorrelationGroupSize()
String	getCorrelationId()
int	getCorrelationSequence()
Object	getPayload()
Object	getReplyTo()
String	getUniqueId()
org.mule.api.ThreadSafeAccess	newThreadCopy()
void	setCorrelationGroupSize(int correlationGroupSize)
void	setCorrelationId(String correlationId)
void	setCorrelationSequence(int sequence)
void	setReplyTo(Object replyTo)

Methods inherited from class org.mule.transport.AbstractMessageAdapter

addAttachment, addInboundProperties, addProperties, addProperties, assertAccess, clearProperties, getAttachment, getAttachmentNames, getBooleanProperty, getDoubleProperty, getEncoding, getExceptionPayload, getIntProperty, getLongProperty, getProperty, getProperty, getProperty, getPropertyNames, getPropertyNames, getStringProperty, isDisabled, newException, release, removeAttachment, removeProperty, resetAccessControl, setBooleanProperty, setDoubleProperty, setEncoding, setExceptionPayload, setIntProperty, setLongProperty, setProperty, setProperty, setStringProperty, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

OpenSpacesMessageAdapter

public OpenSpacesMessageAdapter(Object msg)
                         throws org.mule.api.MessagingException

Throws:

org.mule.api.MessagingException

OpenSpacesMessageAdapter

public OpenSpacesMessageAdapter(OpenSpacesMessageAdapter template)

Method Detail

getPayload

public Object getPayload()

Returns:

the current message

getUniqueId

public String getUniqueId()

Specified by:

getUniqueId in interface org.mule.api.transport.MessageAdapter

Overrides:

getUniqueId in class org.mule.transport.AbstractMessageAdapter

getCorrelationId

public String getCorrelationId()

Specified by:

getCorrelationId in interface org.mule.api.transport.MessageAdapter

Overrides:

getCorrelationId in class org.mule.transport.AbstractMessageAdapter

setCorrelationId

public void setCorrelationId(String correlationId)

Specified by:

setCorrelationId in interface org.mule.api.transport.MessageAdapter

Overrides:

setCorrelationId in class org.mule.transport.AbstractMessageAdapter

getCorrelationSequence

public int getCorrelationSequence()

Specified by:

getCorrelationSequence in interface org.mule.api.transport.MessageAdapter

Overrides:

getCorrelationSequence in class org.mule.transport.AbstractMessageAdapter

setCorrelationSequence

public void setCorrelationSequence(int sequence)

Specified by:

setCorrelationSequence in interface org.mule.api.transport.MessageAdapter

Overrides:

setCorrelationSequence in class org.mule.transport.AbstractMessageAdapter

getCorrelationGroupSize

public int getCorrelationGroupSize()

Specified by:

getCorrelationGroupSize in interface org.mule.api.transport.MessageAdapter

Overrides:

getCorrelationGroupSize in class org.mule.transport.AbstractMessageAdapter

setCorrelationGroupSize

public void setCorrelationGroupSize(int correlationGroupSize)

Specified by:

setCorrelationGroupSize in interface org.mule.api.transport.MessageAdapter

Overrides:

setCorrelationGroupSize in class org.mule.transport.AbstractMessageAdapter

getReplyTo

public Object getReplyTo()

Specified by:

getReplyTo in interface org.mule.api.transport.MessageAdapter

Overrides:

getReplyTo in class org.mule.transport.AbstractMessageAdapter

setReplyTo

public void setReplyTo(Object replyTo)

Specified by:

setReplyTo in interface org.mule.api.transport.MessageAdapter

Overrides:

setReplyTo in class org.mule.transport.AbstractMessageAdapter

newThreadCopy

public org.mule.api.ThreadSafeAccess newThreadCopy()

Specified by:

newThreadCopy in interface org.mule.api.ThreadSafeAccess

Overrides:

newThreadCopy in class org.mule.transport.AbstractMessageAdapter