org.mule.runtime.module.cxf.transport

Class MuleUniversalConduit

java.lang.Object

org.apache.cxf.transport.AbstractObservable

org.apache.cxf.transport.AbstractConduit

org.mule.runtime.module.cxf.transport.MuleUniversalConduit

All Implemented Interfaces:

org.apache.cxf.transport.Conduit, org.apache.cxf.transport.Observable

public class MuleUniversalConduit
extends org.apache.cxf.transport.AbstractConduit

A Conduit is primarily responsible for sending messages from CXF to somewhere else. This conduit takes messages which are being written and sends them to the Mule bus.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	MuleUniversalConduit.InterposedMessageObserver Used to set appropriate message properties, exchange etc.

Field Summary

Fields

Modifier and Type	Field and Description
protected CxfConfiguration	configuration

Fields inherited from class org.apache.cxf.transport.AbstractConduit

target

Fields inherited from class org.apache.cxf.transport.AbstractObservable

incomingObserver

Constructor Summary

Constructors

Constructor and Description
MuleUniversalConduit(MuleUniversalTransport transport, CxfConfiguration configuration, org.apache.cxf.service.model.EndpointInfo ei, org.apache.cxf.ws.addressing.EndpointReferenceType t)

Method Summary

Modifier and Type	Method and Description
void	close()
void	close(org.apache.cxf.message.Message msg)
protected void	dispatchMuleMessage(org.apache.cxf.message.Message m, org.mule.runtime.core.api.Event reqEvent)
protected CxfConfiguration	getConnector()
protected org.apache.cxf.service.model.EndpointInfo	getEndpoint()
protected Logger	getLogger()
protected InputStream	getResponseBody(org.apache.cxf.message.Message m, org.mule.runtime.core.api.Event result)
protected String	getTargetOrEndpoint()
protected static org.apache.cxf.ws.addressing.EndpointReferenceType	getTargetReference(org.apache.cxf.service.model.EndpointInfo ei, org.apache.cxf.ws.addressing.EndpointReferenceType t) Get the target endpoint reference.
protected MuleUniversalTransport	getTransport()
protected boolean	isOneway(org.apache.cxf.message.Exchange exchange)
void	onClose(org.apache.cxf.message.Message m)
void	prepare(org.apache.cxf.message.Message message) Prepare the message for writing.
protected org.mule.runtime.core.api.Event	processNext(org.mule.runtime.core.api.Event event, org.apache.cxf.message.Exchange exchange)
protected void	sendResultBackToCxf(org.apache.cxf.message.Message m, org.mule.runtime.core.api.Event resEvent)
void	setCloseInput(boolean closeInput)
String	setupURL(org.apache.cxf.message.Message message)

Methods inherited from class org.apache.cxf.transport.AbstractConduit

getTarget, toString

Methods inherited from class org.apache.cxf.transport.AbstractObservable

activate, deactivate, getMessageObserver, getTargetReference, getTargetReference, setMessageObserver

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cxf.transport.Observable

getMessageObserver, setMessageObserver

Field Detail

configuration

protected CxfConfiguration configuration

Constructor Detail

MuleUniversalConduit

public MuleUniversalConduit(MuleUniversalTransport transport,
                            CxfConfiguration configuration,
                            org.apache.cxf.service.model.EndpointInfo ei,
                            org.apache.cxf.ws.addressing.EndpointReferenceType t)

Parameters:

ei - The Endpoint being invoked by this destination.

t - The EPR associated with this Conduit - i.e. the reply destination.

Method Detail

close

public void close(org.apache.cxf.message.Message msg)
           throws IOException

Specified by:

close in interface org.apache.cxf.transport.Conduit

Overrides:

close in class org.apache.cxf.transport.AbstractConduit

Throws:

IOException

getLogger

protected Logger getLogger()

Specified by:

getLogger in class org.apache.cxf.transport.AbstractObservable

prepare

public void prepare(org.apache.cxf.message.Message message)
             throws IOException

Prepare the message for writing.

Throws:

IOException

setupURL

public String setupURL(org.apache.cxf.message.Message message)
                throws MalformedURLException

Throws:

MalformedURLException

dispatchMuleMessage

protected void dispatchMuleMessage(org.apache.cxf.message.Message m,
                                   org.mule.runtime.core.api.Event reqEvent)
                            throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException

sendResultBackToCxf

protected void sendResultBackToCxf(org.apache.cxf.message.Message m,
                                   org.mule.runtime.core.api.Event resEvent)
                            throws org.mule.runtime.core.api.transformer.TransformerException,
                                   IOException

Throws:

org.mule.runtime.core.api.transformer.TransformerException

IOException

getResponseBody

protected InputStream getResponseBody(org.apache.cxf.message.Message m,
                                      org.mule.runtime.core.api.Event result)
                               throws org.mule.runtime.core.api.transformer.TransformerException,
                                      IOException

Throws:

org.mule.runtime.core.api.transformer.TransformerException

IOException

isOneway

protected boolean isOneway(org.apache.cxf.message.Exchange exchange)

getTargetOrEndpoint

protected String getTargetOrEndpoint()

onClose

public void onClose(org.apache.cxf.message.Message m)
             throws IOException

Throws:

IOException

processNext

protected org.mule.runtime.core.api.Event processNext(org.mule.runtime.core.api.Event event,
                                                      org.apache.cxf.message.Exchange exchange)
                                               throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException

close

public void close()

Specified by:

close in interface org.apache.cxf.transport.Conduit

Overrides:

close in class org.apache.cxf.transport.AbstractConduit

getTargetReference

protected static org.apache.cxf.ws.addressing.EndpointReferenceType getTargetReference(org.apache.cxf.service.model.EndpointInfo ei,
                                                                                       org.apache.cxf.ws.addressing.EndpointReferenceType t)

Get the target endpoint reference.

Parameters:

ei - the corresponding EndpointInfo

t - the given target EPR if available

Returns:

the actual target

setCloseInput

public void setCloseInput(boolean closeInput)

getConnector

protected CxfConfiguration getConnector()

getEndpoint

protected org.apache.cxf.service.model.EndpointInfo getEndpoint()

getTransport

protected MuleUniversalTransport getTransport()