org.apache.servicemix.jbi.runtime.impl
Class MessageExchangeImpl

java.lang.Object
  org.apache.servicemix.jbi.runtime.impl.MessageExchangeImpl

All Implemented Interfaces:

javax.jbi.messaging.MessageExchange

Direct Known Subclasses:

InOnlyImpl, InOptionalOutImpl, InOutImpl, RobustInOnlyImpl

public class MessageExchangeImpl
extends Object
implements javax.jbi.messaging.MessageExchange

MessageExchange wrapper on top of an Exchange.

See Also:

Exchange

Nested Class Summary

Nested classes/interfaces inherited from interface javax.jbi.messaging.MessageExchange

javax.jbi.messaging.MessageExchange.Role

Field Summary

static String	FAULT
static String	IN
static String	INTERFACE_NAME_PROP
static String	OUT
static String	SERVICE_ENDPOINT_PROP
static String	SERVICE_NAME_PROP

Fields inherited from interface javax.jbi.messaging.MessageExchange

JTA_TRANSACTION_PROPERTY_NAME

Constructor Summary

MessageExchangeImpl(Exchange exchange)

Method Summary

javax.jbi.messaging.Fault	createFault()
javax.jbi.messaging.NormalizedMessage	createMessage()
javax.jbi.servicedesc.ServiceEndpoint	getEndpoint()
static javax.jbi.servicedesc.ServiceEndpoint	getEndpoint(Exchange exchange)
Exception	getError()
String	getExchangeId()
javax.jbi.messaging.Fault	getFault()
javax.jbi.messaging.NormalizedMessage	getInMessage()
QName	getInterfaceName()
static QName	getInterfaceName(Exchange exchange)
Exchange	getInternalExchange()
javax.jbi.messaging.NormalizedMessage	getMessage(String name)
QName	getOperation()
javax.jbi.messaging.NormalizedMessage	getOutMessage()
URI	getPattern()
Object	getProperty(String s)
Set	getPropertyNames()
javax.jbi.messaging.MessageExchange.Role	getRole()
QName	getService()
static QName	getService(Exchange exchange)
javax.jbi.messaging.ExchangeStatus	getStatus()
boolean	isTransacted()
void	setEndpoint(javax.jbi.servicedesc.ServiceEndpoint endpoint)
void	setError(Exception e)
void	setFault(javax.jbi.messaging.Fault message)
void	setInMessage(javax.jbi.messaging.NormalizedMessage message)
void	setInterfaceName(QName interfaceName)
void	setMessage(javax.jbi.messaging.NormalizedMessage msg, String name)
void	setOperation(QName qName)
void	setOutMessage(javax.jbi.messaging.NormalizedMessage message)
void	setProperty(String s, Object o)
void	setService(QName service)
void	setStatus(javax.jbi.messaging.ExchangeStatus status)

Methods inherited from class java.lang.Object

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

Field Detail

INTERFACE_NAME_PROP

public static final String INTERFACE_NAME_PROP

See Also:

Constant Field Values

SERVICE_NAME_PROP

public static final String SERVICE_NAME_PROP

See Also:

Constant Field Values

SERVICE_ENDPOINT_PROP

public static final String SERVICE_ENDPOINT_PROP

See Also:

Constant Field Values

IN

public static final String IN

See Also:

Constant Field Values

OUT

public static final String OUT

See Also:

Constant Field Values

FAULT

public static final String FAULT

See Also:

Constant Field Values

Constructor Detail

MessageExchangeImpl

public MessageExchangeImpl(Exchange exchange)

Method Detail

getInternalExchange

public Exchange getInternalExchange()

getExchangeId

public String getExchangeId()

Specified by:

getExchangeId in interface javax.jbi.messaging.MessageExchange

getPattern

public URI getPattern()

Specified by:

getPattern in interface javax.jbi.messaging.MessageExchange

getRole

public javax.jbi.messaging.MessageExchange.Role getRole()

Specified by:

getRole in interface javax.jbi.messaging.MessageExchange

getStatus

public javax.jbi.messaging.ExchangeStatus getStatus()

Specified by:

getStatus in interface javax.jbi.messaging.MessageExchange

setStatus

public void setStatus(javax.jbi.messaging.ExchangeStatus status)

Specified by:

setStatus in interface javax.jbi.messaging.MessageExchange

getOperation

public QName getOperation()

Specified by:

getOperation in interface javax.jbi.messaging.MessageExchange

setOperation

public void setOperation(QName qName)

Specified by:

setOperation in interface javax.jbi.messaging.MessageExchange

getProperty

public Object getProperty(String s)

Specified by:

getProperty in interface javax.jbi.messaging.MessageExchange

setProperty

public void setProperty(String s,
                        Object o)

Specified by:

setProperty in interface javax.jbi.messaging.MessageExchange

getPropertyNames

public Set getPropertyNames()

Specified by:

getPropertyNames in interface javax.jbi.messaging.MessageExchange

createMessage

public javax.jbi.messaging.NormalizedMessage createMessage()
                                                    throws javax.jbi.messaging.MessagingException

Specified by:

createMessage in interface javax.jbi.messaging.MessageExchange

Throws:

javax.jbi.messaging.MessagingException

getMessage

public javax.jbi.messaging.NormalizedMessage getMessage(String name)

Specified by:

getMessage in interface javax.jbi.messaging.MessageExchange

setMessage

public void setMessage(javax.jbi.messaging.NormalizedMessage msg,
                       String name)
                throws javax.jbi.messaging.MessagingException

Specified by:

setMessage in interface javax.jbi.messaging.MessageExchange

Throws:

javax.jbi.messaging.MessagingException

getInMessage

public javax.jbi.messaging.NormalizedMessage getInMessage()

setInMessage

public void setInMessage(javax.jbi.messaging.NormalizedMessage message)
                  throws javax.jbi.messaging.MessagingException

Throws:

javax.jbi.messaging.MessagingException

getOutMessage

public javax.jbi.messaging.NormalizedMessage getOutMessage()

setOutMessage

public void setOutMessage(javax.jbi.messaging.NormalizedMessage message)
                   throws javax.jbi.messaging.MessagingException

Throws:

javax.jbi.messaging.MessagingException

createFault

public javax.jbi.messaging.Fault createFault()
                                      throws javax.jbi.messaging.MessagingException

Specified by:

createFault in interface javax.jbi.messaging.MessageExchange

Throws:

javax.jbi.messaging.MessagingException

getFault

public javax.jbi.messaging.Fault getFault()

Specified by:

getFault in interface javax.jbi.messaging.MessageExchange

setFault

public void setFault(javax.jbi.messaging.Fault message)
              throws javax.jbi.messaging.MessagingException

Specified by:

setFault in interface javax.jbi.messaging.MessageExchange

Throws:

javax.jbi.messaging.MessagingException

getError

public Exception getError()

Specified by:

getError in interface javax.jbi.messaging.MessageExchange

setError

public void setError(Exception e)

Specified by:

setError in interface javax.jbi.messaging.MessageExchange

setEndpoint

public void setEndpoint(javax.jbi.servicedesc.ServiceEndpoint endpoint)

Specified by:

setEndpoint in interface javax.jbi.messaging.MessageExchange

setService

public void setService(QName service)

Specified by:

setService in interface javax.jbi.messaging.MessageExchange

setInterfaceName

public void setInterfaceName(QName interfaceName)

Specified by:

setInterfaceName in interface javax.jbi.messaging.MessageExchange

getEndpoint

public javax.jbi.servicedesc.ServiceEndpoint getEndpoint()

Specified by:

getEndpoint in interface javax.jbi.messaging.MessageExchange

getInterfaceName

public QName getInterfaceName()

Specified by:

getInterfaceName in interface javax.jbi.messaging.MessageExchange

getService

public QName getService()

Specified by:

getService in interface javax.jbi.messaging.MessageExchange

isTransacted

public boolean isTransacted()

Specified by:

isTransacted in interface javax.jbi.messaging.MessageExchange

getEndpoint

public static javax.jbi.servicedesc.ServiceEndpoint getEndpoint(Exchange exchange)

getInterfaceName

public static QName getInterfaceName(Exchange exchange)

getService

public static QName getService(Exchange exchange)