org.mule.runtime.module.cxf

Class CxfOutboundMessageProcessor

java.lang.Object

org.mule.runtime.core.AbstractAnnotatedObject

org.mule.runtime.core.processor.AbstractInterceptingMessageProcessorBase

org.mule.runtime.core.processor.AbstractInterceptingMessageProcessor

org.mule.runtime.module.cxf.CxfOutboundMessageProcessor

All Implemented Interfaces:

Function<org.reactivestreams.Publisher<org.mule.runtime.core.api.Event>,org.reactivestreams.Publisher<org.mule.runtime.core.api.Event>>, org.mule.runtime.api.meta.AnnotatedObject, org.mule.runtime.core.api.construct.FlowConstructAware, org.mule.runtime.core.api.context.MuleContextAware, org.mule.runtime.core.api.processor.CloneableMessageProcessor, org.mule.runtime.core.api.processor.InterceptingMessageProcessor, org.mule.runtime.core.api.processor.Processor, org.mule.runtime.core.api.processor.ReactiveProcessor

public class CxfOutboundMessageProcessor
extends org.mule.runtime.core.processor.AbstractInterceptingMessageProcessor
implements org.mule.runtime.core.api.processor.CloneableMessageProcessor

The CxfOutboundMessageProcessor performs outbound CXF processing, sending an event through the CXF client, then on to the next MessageProcessor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.mule.runtime.core.api.processor.ReactiveProcessor

org.mule.runtime.core.api.processor.ReactiveProcessor.ProcessingType

Field Summary

Fields inherited from class org.mule.runtime.core.processor.AbstractInterceptingMessageProcessorBase

flowConstruct, logger, muleContext, next

Fields inherited from interface org.mule.runtime.api.meta.AnnotatedObject

PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
CxfOutboundMessageProcessor(org.apache.cxf.endpoint.Client client)

Method Summary

Modifier and Type	Method and Description
protected Object[]	addHoldersToResponse(Object response, Object[] args)
protected org.mule.runtime.core.api.Event	buildResponseMessage(org.mule.runtime.core.api.Event request, org.mule.runtime.core.api.Event transportResponse, Object[] response)
protected void	cleanup()
org.mule.runtime.core.api.processor.Processor	clone()
protected org.mule.runtime.core.api.Event	doSendWithClient(org.mule.runtime.core.api.Event event)
protected org.mule.runtime.core.api.Event	doSendWithProxy(org.mule.runtime.core.api.Event event)
protected Object[]	getArgs(org.mule.runtime.core.api.Event event)
protected org.apache.cxf.service.model.BindingOperationInfo	getBindingOperationFromEndpoint(org.apache.cxf.endpoint.Endpoint ep, String operationName)
org.apache.cxf.endpoint.Client	getClient()
Method	getMethod(org.mule.runtime.core.api.Event event)
protected String	getMethodOrOperationName(org.mule.runtime.core.api.Event event)
org.mule.runtime.api.metadata.MediaType	getMimeType()
String	getOperation()
org.apache.cxf.service.model.BindingOperationInfo	getOperation(org.mule.runtime.core.api.Event event)
protected org.apache.cxf.service.model.BindingOperationInfo	getOperation(String opName)
CxfPayloadToArguments	getPayloadToArguments()
protected boolean	isClientProxyAvailable()
boolean	isProxy()
org.mule.runtime.core.api.Event	process(org.mule.runtime.core.api.Event event)
org.mule.runtime.core.api.Event	processNext(org.mule.runtime.core.api.Event event) This method is public so it can be invoked from the MuleUniversalConduit.
void	setClientProxy(BindingProvider clientProxy)
void	setDecoupledEndpoint(String decoupledEndpoint)
void	setMimeType(org.mule.runtime.api.metadata.MediaType mimeType)
void	setOperation(String operation)
void	setPayloadToArguments(CxfPayloadToArguments payloadToArguments)
void	setProxy(boolean proxy)
protected org.apache.cxf.service.model.BindingOperationInfo	tryToGetTheOperationInDotNetNamingConvention(org.apache.cxf.endpoint.Endpoint ep, String opName) This method tries to call getBindingOperationFromEndpoint(Endpoint, String) with the .NET naming convention for .NET webservices (method names start with a capital letter).

Methods inherited from class org.mule.runtime.core.processor.AbstractInterceptingMessageProcessorBase

applyNext, getListener, getMuleContext, isEventValid, setFlowConstruct, setListener, setMuleContext, toString

Methods inherited from class org.mule.runtime.core.AbstractAnnotatedObject

getAnnotation, getAnnotations, setAnnotations

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.mule.runtime.core.api.processor.InterceptingMessageProcessor

setListener

Methods inherited from interface org.mule.runtime.core.api.processor.Processor

apply

Methods inherited from interface org.mule.runtime.core.api.processor.ReactiveProcessor

getProccesingType

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

CxfOutboundMessageProcessor

public CxfOutboundMessageProcessor(org.apache.cxf.endpoint.Client client)

Method Detail

cleanup

protected void cleanup()

getArgs

protected Object[] getArgs(org.mule.runtime.core.api.Event event)
                    throws org.mule.runtime.core.api.transformer.TransformerException

Throws:

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

process

public org.mule.runtime.core.api.Event process(org.mule.runtime.core.api.Event event)
                                        throws org.mule.runtime.api.exception.MuleException

Specified by:

process in interface org.mule.runtime.core.api.processor.Processor

Throws:

org.mule.runtime.api.exception.MuleException

processNext

public org.mule.runtime.core.api.Event processNext(org.mule.runtime.core.api.Event event)
                                            throws org.mule.runtime.api.exception.MuleException

This method is public so it can be invoked from the MuleUniversalConduit.

Overrides:

processNext in class org.mule.runtime.core.processor.AbstractInterceptingMessageProcessorBase

Throws:

org.mule.runtime.api.exception.MuleException

doSendWithProxy

protected org.mule.runtime.core.api.Event doSendWithProxy(org.mule.runtime.core.api.Event event)
                                                   throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException

doSendWithClient

protected org.mule.runtime.core.api.Event doSendWithClient(org.mule.runtime.core.api.Event event)
                                                    throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException

getMethod

public Method getMethod(org.mule.runtime.core.api.Event event)
                 throws Exception

Throws:

Exception

getOperation

protected org.apache.cxf.service.model.BindingOperationInfo getOperation(String opName)
                                                                  throws Exception

Throws:

Exception

tryToGetTheOperationInDotNetNamingConvention

protected org.apache.cxf.service.model.BindingOperationInfo tryToGetTheOperationInDotNetNamingConvention(org.apache.cxf.endpoint.Endpoint ep,
                                                                                                         String opName)

This method tries to call getBindingOperationFromEndpoint(Endpoint, String) with the .NET naming convention for .NET webservices (method names start with a capital letter).

CXF generates method names compliant with Java naming so if the WSDL operation names starts with uppercase letter, matching with method name does not work - thus the work around.

getBindingOperationFromEndpoint

protected org.apache.cxf.service.model.BindingOperationInfo getBindingOperationFromEndpoint(org.apache.cxf.endpoint.Endpoint ep,
                                                                                            String operationName)

getMethodOrOperationName

protected String getMethodOrOperationName(org.mule.runtime.core.api.Event event)
                                   throws org.mule.runtime.core.api.connector.DispatchException

Throws:

org.mule.runtime.core.api.connector.DispatchException

getOperation

public org.apache.cxf.service.model.BindingOperationInfo getOperation(org.mule.runtime.core.api.Event event)
                                                               throws Exception

Throws:

Exception

buildResponseMessage

protected org.mule.runtime.core.api.Event buildResponseMessage(org.mule.runtime.core.api.Event request,
                                                               org.mule.runtime.core.api.Event transportResponse,
                                                               Object[] response)

addHoldersToResponse

protected Object[] addHoldersToResponse(Object response,
                                        Object[] args)

setPayloadToArguments

public void setPayloadToArguments(CxfPayloadToArguments payloadToArguments)

isClientProxyAvailable

protected boolean isClientProxyAvailable()

isProxy

public boolean isProxy()

setProxy

public void setProxy(boolean proxy)

getOperation

public String getOperation()

setOperation

public void setOperation(String operation)

setClientProxy

public void setClientProxy(BindingProvider clientProxy)

getPayloadToArguments

public CxfPayloadToArguments getPayloadToArguments()

getClient

public org.apache.cxf.endpoint.Client getClient()

setDecoupledEndpoint

public void setDecoupledEndpoint(String decoupledEndpoint)

clone

public org.mule.runtime.core.api.processor.Processor clone()

Specified by:

clone in interface org.mule.runtime.core.api.processor.CloneableMessageProcessor

Overrides:

clone in class Object

getMimeType

public org.mule.runtime.api.metadata.MediaType getMimeType()

setMimeType

public void setMimeType(org.mule.runtime.api.metadata.MediaType mimeType)