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

java.lang.Object
  extended by 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)


Copyright © 2005-2012 FuseSource. All Rights Reserved.