@UriEndpoint(scheme="cxf", title="CXF", syntax="cxf:beanId:address", consumerClass=CxfConsumer.class, label="soap,webservice") public class CxfEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.spi.HeaderFilterStrategyAware, org.apache.camel.Service, Cloneable
Modifier and Type | Field and Description |
---|---|
protected org.apache.cxf.Bus |
bus |
Constructor and Description |
---|
CxfEndpoint() |
CxfEndpoint(String remaining)
Deprecated.
|
CxfEndpoint(String remaining,
org.apache.camel.CamelContext context)
Deprecated.
|
CxfEndpoint(String remaining,
CxfComponent cxfComponent) |
Modifier and Type | Method and Description |
---|---|
CxfEndpoint |
copy() |
protected org.apache.cxf.frontend.ClientFactoryBean |
createClientFactoryBean()
Create a client factory bean object without serviceClass interface.
|
protected org.apache.cxf.frontend.ClientFactoryBean |
createClientFactoryBean(Class<?> cls)
Create a client factory bean object.
|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
String |
getAddress() |
Boolean |
getAllowStreaming() |
String |
getBeanId() |
org.apache.cxf.binding.BindingConfiguration |
getBindingConfig() |
String |
getBindingId() |
org.apache.cxf.Bus |
getBus() |
long |
getContinuationTimeout() |
CxfBinding |
getCxfBinding() |
CxfEndpointConfigurer |
getCxfEndpointConfigurer() |
org.apache.cxf.databinding.DataBinding |
getDataBinding() |
DataFormat |
getDataFormat() |
String |
getDefaultOperationName() |
String |
getDefaultOperationNamespace() |
List<org.apache.cxf.feature.Feature> |
getFeatures() |
List<Handler> |
getHandlers() |
org.apache.camel.spi.HeaderFilterStrategy |
getHeaderFilterStrategy() |
List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> |
getInFaultInterceptors() |
List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> |
getInInterceptors() |
int |
getLoggingSizeLimit() |
Boolean |
getMergeProtocolHeaders() |
List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> |
getOutFaultInterceptors() |
List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> |
getOutInterceptors() |
String |
getPassword() |
QName |
getPortName() |
Map<String,Object> |
getProperties() |
String |
getPublishedEndpointUrl() |
List<String> |
getSchemaLocations() |
Class<?> |
getServiceClass() |
Object |
getServiceFactoryBean() |
QName |
getServiceName() |
String |
getTransportId() |
String |
getUsername() |
Boolean |
getWrappedStyle() |
String |
getWsdlURL() |
boolean |
isDefaultBus() |
boolean |
isLoggingFeatureEnabled() |
boolean |
isMtomEnabled() |
boolean |
isSingleton() |
boolean |
isSkipFaultLogging() |
boolean |
isSkipPayloadMessagePartCheck() |
boolean |
isWrapped() |
protected String |
resolvePropertyPlaceholders(String str) |
void |
setAddress(String address)
The service publish address.
|
void |
setAllowStreaming(Boolean allowStreaming)
This option controls whether the CXF component, when running in PAYLOAD mode, will DOM parse the incoming messages
into DOM Elements or keep the payload as a javax.xml.transform.Source object that would allow streaming in some cases.
|
void |
setBeanId(String beanId) |
void |
setBindingConfig(org.apache.cxf.binding.BindingConfiguration bindingConfig) |
void |
setBindingId(String bindingId)
The bindingId for the service model to use.
|
void |
setBus(org.apache.cxf.Bus bus)
To use a custom configured CXF Bus.
|
void |
setCamelContext(org.apache.camel.CamelContext c) |
void |
setContinuationTimeout(long continuationTimeout)
This option is used to set the CXF continuation timeout which could be used in CxfConsumer by default when the CXF server is using Jetty or Servlet transport.
|
void |
setCxfBinding(CxfBinding cxfBinding)
To use a custom CxfBinding to control the binding between Camel Message and CXF Message.
|
void |
setCxfEndpointConfigurer(CxfEndpointConfigurer configurer)
This option could apply the implementation of org.apache.camel.component.cxf.CxfEndpointConfigurer which supports to configure the CXF endpoint
in programmatic way.
|
void |
setDataBinding(org.apache.cxf.databinding.DataBinding dataBinding) |
void |
setDataFormat(DataFormat format)
The data type messages supported by the CXF endpoint.
|
void |
setDefaultBus(boolean defaultBus)
Will set the default bus when CXF endpoint create a bus by itself
|
void |
setDefaultOperationName(String name)
This option will set the default operationName that will be used by the CxfProducer which invokes the remote service.
|
void |
setDefaultOperationNamespace(String namespace)
This option will set the default operationNamespace that will be used by the CxfProducer which invokes the remote service.
|
void |
setEndpointName(QName port)
The port name this service is implementing, it maps to the wsdl:port@name.
|
void |
setEndpointNameString(String port)
The port name this service is implementing, it maps to the wsdl:port@name.
|
void |
setFeatures(List<org.apache.cxf.feature.Feature> f) |
void |
setHandlers(List<Handler> h) |
void |
setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
To use a custom HeaderFilterStrategy to filter header to and from Camel message.
|
void |
setInFaultInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors) |
void |
setInInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors) |
void |
setLoggingFeatureEnabled(boolean loggingFeatureEnabled)
This option enables CXF Logging Feature which writes inbound and outbound SOAP messages to log.
|
void |
setLoggingSizeLimit(int loggingSizeLimit)
To limit the total size of number of bytes the logger will output when logging feature has been enabled and -1 for no limit.
|
void |
setMergeProtocolHeaders(boolean mergeProtocolHeaders)
Whether to merge protocol headers.
|
void |
setMtomEnabled(boolean mtomEnabled)
To enable MTOM (attachments).
|
void |
setOutFaultInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors) |
void |
setOutInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors) |
void |
setPassword(String password)
This option is used to set the basic authentication information of password for the CXF client.
|
void |
setPortName(QName port)
The endpoint name this service is implementing, it maps to the wsdl:port@name.
|
void |
setPortName(String portName) |
void |
setPortNameString(String portNameString)
The endpoint name this service is implementing, it maps to the wsdl:port@name.
|
void |
setProperties(Map<String,Object> properties)
To set additional CXF options using the key/value pairs from the Map.
|
void |
setPublishedEndpointUrl(String url)
This option can override the endpointUrl that published from the WSDL which can be accessed with service address url plus ?wsd
|
void |
setSchemaLocations(List<String> sc) |
void |
setService(String service)
The service name this service is implementing, it maps to the wsdl:service@name.
|
void |
setServiceClass(Class<?> cls)
The class name of the SEI (Service Endpoint Interface) class which could have JSR181 annotation or not.
|
void |
setServiceClass(Object instance)
The class name of the SEI (Service Endpoint Interface) class which could have JSR181 annotation or not.
|
void |
setServiceClass(String type)
The class name of the SEI (Service Endpoint Interface) class which could have JSR181 annotation or not.
|
void |
setServiceFactory(Object serviceFactoryBean) |
void |
setServiceFactoryBean(Object serviceFactoryBean) |
void |
setServiceName(QName service)
The service name this service is implementing, it maps to the wsdl:service@name.
|
void |
setServiceNameString(String service)
The service name this service is implementing, it maps to the wsdl:service@name.
|
void |
setSkipFaultLogging(boolean skipFaultLogging)
This option controls whether the PhaseInterceptorChain skips logging the Fault that it catches.
|
void |
setSkipPayloadMessagePartCheck(boolean skipPayloadMessagePartCheck)
Sets whether SOAP message validation should be disabled.
|
void |
setTransportId(String transportId) |
protected void |
setupClientFactoryBean(org.apache.cxf.frontend.ClientFactoryBean factoryBean,
Class<?> cls) |
protected void |
setupHandlers(org.apache.cxf.frontend.ClientFactoryBean factoryBean,
org.apache.cxf.endpoint.Client client) |
protected void |
setupServerFactoryBean(org.apache.cxf.frontend.ServerFactoryBean sfb,
Class<?> cls)
Populate server factory bean
|
void |
setUsername(String username)
This option is used to set the basic authentication information of username for the CXF client.
|
void |
setWrapped(boolean wrapped)
Which kind of operation that CXF endpoint producer will invoke
|
void |
setWrappedStyle(Boolean wrapped)
The WSDL style that describes how parameters are represented in the SOAP body.
|
void |
setWsdlURL(String url)
The location of the WSDL.
|
protected void |
updateEndpointUri(String endpointUri) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public CxfEndpoint()
public CxfEndpoint(String remaining, CxfComponent cxfComponent)
@Deprecated public CxfEndpoint(String remaining, org.apache.camel.CamelContext context)
@Deprecated public CxfEndpoint(String remaining)
public CxfEndpoint copy()
protected void updateEndpointUri(String endpointUri)
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
protected void setupServerFactoryBean(org.apache.cxf.frontend.ServerFactoryBean sfb, Class<?> cls)
protected org.apache.cxf.frontend.ClientFactoryBean createClientFactoryBean(Class<?> cls) throws org.apache.camel.CamelException
org.apache.camel.CamelException
protected org.apache.cxf.frontend.ClientFactoryBean createClientFactoryBean()
protected void setupHandlers(org.apache.cxf.frontend.ClientFactoryBean factoryBean, org.apache.cxf.endpoint.Client client) throws Exception
Exception
protected void setupClientFactoryBean(org.apache.cxf.frontend.ClientFactoryBean factoryBean, Class<?> cls)
public String getBeanId()
public void setBeanId(String beanId)
public DataFormat getDataFormat()
public void setDataFormat(DataFormat format)
public String getPublishedEndpointUrl()
public void setPublishedEndpointUrl(String url)
public String getWsdlURL()
public void setWsdlURL(String url)
public Class<?> getServiceClass()
public void setServiceClass(Class<?> cls)
public void setServiceClass(Object instance)
public void setServiceClass(String type) throws ClassNotFoundException
ClassNotFoundException
public void setServiceNameString(String service)
public void setServiceName(QName service)
public void setService(String service)
public QName getServiceName()
public QName getPortName()
public void setPortName(QName port)
public void setPortNameString(String portNameString)
public void setPortName(String portName)
public void setEndpointNameString(String port)
public void setEndpointName(QName port)
public String getDefaultOperationName()
public void setDefaultOperationName(String name)
public String getDefaultOperationNamespace()
public void setDefaultOperationNamespace(String namespace)
public boolean isWrapped()
public void setWrapped(boolean wrapped)
public Boolean getWrappedStyle()
public void setWrappedStyle(Boolean wrapped)
public void setAllowStreaming(Boolean allowStreaming)
public Boolean getAllowStreaming()
public void setCxfBinding(CxfBinding cxfBinding)
public CxfBinding getCxfBinding()
public void setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
setHeaderFilterStrategy
in interface org.apache.camel.spi.HeaderFilterStrategyAware
public org.apache.camel.spi.HeaderFilterStrategy getHeaderFilterStrategy()
getHeaderFilterStrategy
in interface org.apache.camel.spi.HeaderFilterStrategyAware
public void setBus(org.apache.cxf.Bus bus)
public org.apache.cxf.Bus getBus()
public void setDefaultBus(boolean defaultBus)
public boolean isDefaultBus()
public void setLoggingFeatureEnabled(boolean loggingFeatureEnabled)
public boolean isLoggingFeatureEnabled()
public int getLoggingSizeLimit()
public void setLoggingSizeLimit(int loggingSizeLimit)
public boolean isSkipPayloadMessagePartCheck()
public void setSkipPayloadMessagePartCheck(boolean skipPayloadMessagePartCheck)
public void setCamelContext(org.apache.camel.CamelContext c)
setCamelContext
in interface org.apache.camel.CamelContextAware
setCamelContext
in interface org.apache.camel.Endpoint
setCamelContext
in class org.apache.camel.impl.DefaultEndpoint
public void setProperties(Map<String,Object> properties)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
public void setAddress(String address)
public String getAddress()
public void setMtomEnabled(boolean mtomEnabled)
public boolean isMtomEnabled()
public String getPassword()
public void setPassword(String password)
public String getUsername()
public void setUsername(String username)
public List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> getOutFaultInterceptors()
public List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> getInFaultInterceptors()
public List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> getInInterceptors()
public List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> getOutInterceptors()
public void setInInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors)
public void setInFaultInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors)
public void setOutInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors)
public void setOutFaultInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors)
public void setFeatures(List<org.apache.cxf.feature.Feature> f)
public List<org.apache.cxf.feature.Feature> getFeatures()
public String getTransportId()
public void setTransportId(String transportId)
public String getBindingId()
public void setBindingId(String bindingId)
public org.apache.cxf.binding.BindingConfiguration getBindingConfig()
public boolean isSkipFaultLogging()
public void setSkipFaultLogging(boolean skipFaultLogging)
public Boolean getMergeProtocolHeaders()
public void setMergeProtocolHeaders(boolean mergeProtocolHeaders)
public void setBindingConfig(org.apache.cxf.binding.BindingConfiguration bindingConfig)
public org.apache.cxf.databinding.DataBinding getDataBinding()
public void setDataBinding(org.apache.cxf.databinding.DataBinding dataBinding)
public Object getServiceFactoryBean()
public void setServiceFactoryBean(Object serviceFactoryBean)
public void setServiceFactory(Object serviceFactoryBean)
public CxfEndpointConfigurer getCxfEndpointConfigurer()
public void setCxfEndpointConfigurer(CxfEndpointConfigurer configurer)
public long getContinuationTimeout()
public void setContinuationTimeout(long continuationTimeout)
Apache Camel