org.ow2.petals.jbi.messaging.exchange
Class PersistedMessageExchangeWrapper

java.lang.Object
  org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper
      org.ow2.petals.jbi.messaging.exchange.PersistedMessageExchangeWrapper

All Implemented Interfaces:

javax.jbi.messaging.MessageExchange

Direct Known Subclasses:

InOnlyImpl, InOutImpl

public class PersistedMessageExchangeWrapper
extends org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Nested Class Summary

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

javax.jbi.messaging.MessageExchange.Role

Field Summary

Fields inherited from class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

exchangeId, messageExchange

Fields inherited from interface javax.jbi.messaging.MessageExchange

JTA_TRANSACTION_PROPERTY_NAME

Constructor Summary

PersistedMessageExchangeWrapper(org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl me, javax.jbi.messaging.MessageExchange.Role observerRole)

Method Summary

javax.jbi.messaging.Fault	createFault()
javax.jbi.messaging.NormalizedMessage	createMessage()
ServiceEndpoint	getConsumerEndpoint()
javax.jbi.servicedesc.ServiceEndpoint	getEndpoint()
java.lang.Exception	getError()
javax.jbi.messaging.Fault	getFault()
javax.xml.namespace.QName	getInterfaceName()
javax.jbi.messaging.NormalizedMessage	getMessage(java.lang.String name)
org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl	getMessageExchange() Return the real implementation of this MessageExchange.
java.util.Map<java.lang.String,javax.jbi.messaging.NormalizedMessage>	getMessages() Get all the normalized messages
javax.xml.namespace.QName	getOperation()
java.net.URI	getPattern()
java.lang.Object	getProperty(java.lang.String name)
java.util.Set<?>	getPropertyNames()
javax.jbi.messaging.MessageExchange.Role	getRole()
javax.xml.namespace.QName	getService()
javax.jbi.messaging.ExchangeStatus	getStatus()
boolean	isTerminated() Is terminated?
boolean	isTransacted()
void	persistExchange(PersistenceService persistenceService) Persist the wrapped exchange.
void	setEndpoint(javax.jbi.servicedesc.ServiceEndpoint endpoint)
void	setError(java.lang.Exception error)
void	setFault(javax.jbi.messaging.Fault fault)
void	setInterfaceName(javax.xml.namespace.QName interfaceName)
void	setMessage(javax.jbi.messaging.NormalizedMessage msg, java.lang.String name)
void	setOperation(javax.xml.namespace.QName name)
void	setPersisted(boolean persisted) Set the persisted flag.
void	setProperty(java.lang.String name, java.lang.Object obj)
void	setRole(javax.jbi.messaging.MessageExchange.Role role) Set the role.
void	setService(javax.xml.namespace.QName service)
void	setStatus(javax.jbi.messaging.ExchangeStatus status)
void	setTerminated(boolean terminated) Set the terminated flag.

Methods inherited from class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getExchangeId, getFlowAttributes, getObserverRole, isMessageExchangeStored, isTimeout, setFlowAttributes, setMessageExchange, setObserverRole, setTimeout, setTransacted

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistedMessageExchangeWrapper

public PersistedMessageExchangeWrapper(org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl me,
                                       javax.jbi.messaging.MessageExchange.Role observerRole)

Method Detail

createFault

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

Specified by:

createFault in interface javax.jbi.messaging.MessageExchange

Overrides:

createFault in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Throws:

javax.jbi.messaging.MessagingException

createMessage

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

Specified by:

createMessage in interface javax.jbi.messaging.MessageExchange

Overrides:

createMessage in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Throws:

javax.jbi.messaging.MessagingException

getConsumerEndpoint

public ServiceEndpoint getConsumerEndpoint()

Overrides:

getConsumerEndpoint in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getEndpoint

public javax.jbi.servicedesc.ServiceEndpoint getEndpoint()

Specified by:

getEndpoint in interface javax.jbi.messaging.MessageExchange

Overrides:

getEndpoint in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getError

public java.lang.Exception getError()

Specified by:

getError in interface javax.jbi.messaging.MessageExchange

Overrides:

getError in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getFault

public javax.jbi.messaging.Fault getFault()

Specified by:

getFault in interface javax.jbi.messaging.MessageExchange

Overrides:

getFault in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getInterfaceName

public javax.xml.namespace.QName getInterfaceName()

Specified by:

getInterfaceName in interface javax.jbi.messaging.MessageExchange

Overrides:

getInterfaceName in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getMessage

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

Specified by:

getMessage in interface javax.jbi.messaging.MessageExchange

Overrides:

getMessage in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getMessageExchange

public org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl getMessageExchange()

Return the real implementation of this MessageExchange.

Overrides:

getMessageExchange in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Returns:

MessageExchangeImpl

getMessages

public java.util.Map<java.lang.String,javax.jbi.messaging.NormalizedMessage> getMessages()

Get all the normalized messages

Overrides:

getMessages in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Returns:

getOperation

public javax.xml.namespace.QName getOperation()

Specified by:

getOperation in interface javax.jbi.messaging.MessageExchange

Overrides:

getOperation in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getPattern

public java.net.URI getPattern()

Specified by:

getPattern in interface javax.jbi.messaging.MessageExchange

Overrides:

getPattern in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getProperty

public java.lang.Object getProperty(java.lang.String name)

Specified by:

getProperty in interface javax.jbi.messaging.MessageExchange

Overrides:

getProperty in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getPropertyNames

public java.util.Set<?> getPropertyNames()

Specified by:

getPropertyNames in interface javax.jbi.messaging.MessageExchange

Overrides:

getPropertyNames in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getRole

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

Specified by:

getRole in interface javax.jbi.messaging.MessageExchange

Overrides:

getRole in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getService

public javax.xml.namespace.QName getService()

Specified by:

getService in interface javax.jbi.messaging.MessageExchange

Overrides:

getService in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

getStatus

public javax.jbi.messaging.ExchangeStatus getStatus()

Specified by:

getStatus in interface javax.jbi.messaging.MessageExchange

Overrides:

getStatus in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

isTerminated

public boolean isTerminated()

Is terminated?

Overrides:

isTerminated in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Returns:

isTransacted

public boolean isTransacted()

Specified by:

isTransacted in interface javax.jbi.messaging.MessageExchange

Overrides:

isTransacted in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

setEndpoint

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

Specified by:

setEndpoint in interface javax.jbi.messaging.MessageExchange

Overrides:

setEndpoint in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

setError

public void setError(java.lang.Exception error)

Specified by:

setError in interface javax.jbi.messaging.MessageExchange

Overrides:

setError in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

setFault

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

Specified by:

setFault in interface javax.jbi.messaging.MessageExchange

Overrides:

setFault in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Throws:

javax.jbi.messaging.MessagingException

setInterfaceName

public void setInterfaceName(javax.xml.namespace.QName interfaceName)

Specified by:

setInterfaceName in interface javax.jbi.messaging.MessageExchange

Overrides:

setInterfaceName in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

setMessage

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

Specified by:

setMessage in interface javax.jbi.messaging.MessageExchange

Overrides:

setMessage in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Throws:

javax.jbi.messaging.MessagingException

setOperation

public void setOperation(javax.xml.namespace.QName name)

Specified by:

setOperation in interface javax.jbi.messaging.MessageExchange

Overrides:

setOperation in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

setPersisted

public void setPersisted(boolean persisted)

Set the persisted flag.

Overrides:

setPersisted in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Parameters:

role -

setProperty

public void setProperty(java.lang.String name,
                        java.lang.Object obj)

Specified by:

setProperty in interface javax.jbi.messaging.MessageExchange

Overrides:

setProperty in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

setRole

public void setRole(javax.jbi.messaging.MessageExchange.Role role)

Set the role.

Overrides:

setRole in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Parameters:

role -

setService

public void setService(javax.xml.namespace.QName service)

Specified by:

setService in interface javax.jbi.messaging.MessageExchange

Overrides:

setService in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

setStatus

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

Specified by:

setStatus in interface javax.jbi.messaging.MessageExchange

Overrides:

setStatus in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Throws:

javax.jbi.messaging.MessagingException

setTerminated

public void setTerminated(boolean terminated)

Set the terminated flag.

Overrides:

setTerminated in class org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper

Parameters:

terminated -

persistExchange

public void persistExchange(PersistenceService persistenceService)
                     throws java.sql.SQLException,
                            java.io.IOException

Persist the wrapped exchange.
Hold the PersistenceService reference to retrieve the exchange from the persistence service when necessary.

Parameters:

persistenceService -

Throws:

java.sql.SQLException

java.io.IOException