public class CxfInboundMessageProcessor extends AbstractInterceptingMessageProcessor implements Lifecycle, NonBlockingSupported
Server
that it dispatches to.Modifier and Type | Field and Description |
---|---|
protected org.apache.cxf.Bus |
bus |
static String |
JMS_TRANSPORT |
protected Log |
logger
logger used by this class
|
protected org.apache.cxf.endpoint.Server |
server |
protected String |
transportClass |
muleContext, next, notificationHandler
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
CxfInboundMessageProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
dispose()
A lifecycle method where implementor should free up any resources.
|
protected MuleEvent |
generateWSDLOrXSD(MuleEvent event,
String req) |
org.apache.cxf.Bus |
getBus() |
protected InputStream |
getMessageStream(MuleEvent context)
Gets the stream representation of the current message.
|
protected OutputHandler |
getResponseOutputHandler(org.apache.cxf.message.Exchange exchange) |
protected OutputHandler |
getResponseOutputHandler(org.apache.cxf.message.MessageImpl m) |
protected OutputHandler |
getRessponseOutputHandler(org.apache.cxf.message.MessageImpl m)
Deprecated.
|
org.apache.cxf.endpoint.Server |
getServer() |
protected String |
getSoapAction(MuleMessage message) |
void |
initialise()
Method used to perform any initialisation work.
|
boolean |
isProxy() |
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor.
|
MuleEvent |
processNext(MuleEvent event) |
protected MuleEvent |
sendToDestination(MuleEvent event) |
void |
setBus(org.apache.cxf.Bus bus) |
void |
setProxy(boolean proxy) |
void |
setServer(org.apache.cxf.endpoint.Server server) |
void |
setWSDLQueryHandler(org.apache.cxf.transports.http.QueryHandler wsdlQueryHandler) |
protected boolean |
shouldSoapActionHeader() |
void |
start() |
void |
stop() |
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, setListener, setMuleContext, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
public static final String JMS_TRANSPORT
protected transient Log logger
protected org.apache.cxf.Bus bus
protected String transportClass
protected org.apache.cxf.endpoint.Server server
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered frompublic void stop() throws MuleException
stop
in interface Stoppable
MuleException
public void start() throws MuleException
start
in interface Startable
MuleException
public void dispose()
Disposable
dispose
in interface Disposable
public MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
process
in interface MessageProcessor
event
- MuleEvent to be processedMuleException
protected MuleEvent generateWSDLOrXSD(MuleEvent event, String req) throws EndpointNotFoundException, IOException
EndpointNotFoundException
IOException
protected MuleEvent sendToDestination(MuleEvent event) throws MuleException, IOException
MuleException
IOException
protected boolean shouldSoapActionHeader()
public MuleEvent processNext(MuleEvent event) throws MuleException
processNext
in class AbstractInterceptingMessageProcessorBase
MuleException
@Deprecated protected OutputHandler getRessponseOutputHandler(org.apache.cxf.message.MessageImpl m)
protected OutputHandler getResponseOutputHandler(org.apache.cxf.message.MessageImpl m)
protected OutputHandler getResponseOutputHandler(org.apache.cxf.message.Exchange exchange)
protected InputStream getMessageStream(MuleEvent context) throws MuleException
context
- the event contextMuleException
protected String getSoapAction(MuleMessage message)
public org.apache.cxf.Bus getBus()
public void setBus(org.apache.cxf.Bus bus)
public org.apache.cxf.endpoint.Server getServer()
public void setServer(org.apache.cxf.endpoint.Server server)
public void setProxy(boolean proxy)
public boolean isProxy()
public void setWSDLQueryHandler(org.apache.cxf.transports.http.QueryHandler wsdlQueryHandler)
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.