org.mule.transport.cxf.transport
Class MuleUniversalConduit
java.lang.Object
org.apache.cxf.transport.AbstractObservable
org.apache.cxf.transport.AbstractConduit
org.mule.transport.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.
Fields inherited from class org.apache.cxf.transport.AbstractConduit |
target |
Fields inherited from class org.apache.cxf.transport.AbstractObservable |
incomingObserver |
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 interface org.apache.cxf.transport.Observable |
setMessageObserver |
MuleUniversalConduit
public MuleUniversalConduit(MuleUniversalTransport transport,
CxfConnector connector,
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.
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
getBackChannel
public org.apache.cxf.transport.Destination getBackChannel()
- Specified by:
getBackChannel
in interface org.apache.cxf.transport.Conduit
- Overrides:
getBackChannel
in class org.apache.cxf.transport.AbstractConduit
setUpDecoupledDestination
protected void setUpDecoupledDestination()
prepare
public void prepare(org.apache.cxf.message.Message message)
throws IOException
- Prepare the message for writing.
- Throws:
IOException
dispatchMuleMessage
protected void dispatchMuleMessage(org.apache.cxf.message.Message m)
throws IOException
- Throws:
IOException
getProtocolEndpoint
protected OutboundEndpoint getProtocolEndpoint(String uri)
throws MuleException
- Throws:
MuleException
initializeProtocolEndpoint
protected OutboundEndpoint initializeProtocolEndpoint(String uri)
throws MuleException
- Throws:
MuleException
getResponseBody
protected InputStream getResponseBody(org.apache.cxf.message.Message m,
MuleMessage result)
throws TransformerException,
IOException
- Throws:
TransformerException
IOException
isOneway
protected boolean isOneway(org.apache.cxf.message.Exchange exchange)
setupURL
protected String setupURL(org.apache.cxf.message.Message message)
throws MalformedURLException
- Throws:
MalformedURLException
getTargetOrEndpoint
protected String getTargetOrEndpoint()
onClose
public void onClose(org.apache.cxf.message.Message m)
throws IOException
- Throws:
IOException
sendStream
protected MuleMessage sendStream(MessageAdapter sa,
OutboundEndpoint ep,
org.apache.cxf.message.Exchange exchange)
throws MuleException
- Throws:
MuleException
close
public void close()
- Specified by:
close
in interface org.apache.cxf.transport.Conduit
- Overrides:
close
in class org.apache.cxf.transport.AbstractConduit
duplicateDecoupledDestination
protected void duplicateDecoupledDestination()
releaseDecoupledDestination
protected void releaseDecoupledDestination()
getDecoupledEndpoint
public String getDecoupledEndpoint()
setDecoupledEndpoint
public void setDecoupledEndpoint(String decoupledEndpoint)
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 EndpointInfot
- the given target EPR if availablebus
- the Bus
- Returns:
- the actual target
setCloseInput
public void setCloseInput(boolean closeInput)
setApplyTransformersToProtocol
public void setApplyTransformersToProtocol(boolean applyTransformersToProtocol)
getConnector
protected CxfConnector getConnector()
getEndpoint
protected org.apache.cxf.service.model.EndpointInfo getEndpoint()
getTransport
protected MuleUniversalTransport getTransport()
setMuleEndpoint
public void setMuleEndpoint(ImmutableEndpoint muleEndpoint)
Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.