@UriEndpoint(scheme="cxf", title="CXF", syntax="cxf:beanId:address", consumerClass=CxfConsumer.class, label="http,soap,webservice") public class CxfEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.spi.HeaderFilterStrategyAware, org.apache.camel.Service, Cloneable
DataFormat
,
CxfBinding
, and HeaderFilterStrategy
. The default DataFormat
mode is DataFormat.POJO
.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 |
isInOut() |
boolean |
isLoggingFeatureEnabled() |
boolean |
isMtomEnabled() |
boolean |
isSetDefaultBus() |
boolean |
isSingleton() |
boolean |
isSkipFaultLogging() |
protected boolean |
isSkipPayloadMessagePartCheck() |
boolean |
isWrapped() |
protected String |
resolvePropertyPlaceholders(String str) |
void |
setAddress(String address) |
void |
setAllowStreaming(Boolean b) |
void |
setBeanId(String beanId) |
void |
setBindingConfig(org.apache.cxf.binding.BindingConfiguration bindingConfig) |
void |
setBindingId(String bindingId) |
void |
setBus(org.apache.cxf.Bus bus) |
void |
setCamelContext(org.apache.camel.CamelContext c) |
void |
setContinuationTimeout(long continuationTimeout) |
void |
setCxfBinding(CxfBinding cxfBinding) |
void |
setCxfEndpointConfigurer(CxfEndpointConfigurer configurer) |
void |
setDataBinding(org.apache.cxf.databinding.DataBinding dataBinding) |
void |
setDataFormat(DataFormat format) |
void |
setDefaultOperationName(String name) |
void |
setDefaultOperationNamespace(String namespace) |
void |
setEndpointName(QName port) |
void |
setEndpointNameString(String port) |
void |
setFeatures(List<org.apache.cxf.feature.Feature> f) |
void |
setHandlers(List<Handler> h) |
void |
setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) |
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 |
setInOut(boolean inOut) |
void |
setLoggingFeatureEnabled(boolean loggingFeatureEnabled) |
void |
setLoggingSizeLimit(int loggingSizeLimit) |
void |
setMergeProtocolHeaders(boolean mergeProtocolHeaders) |
void |
setMtomEnabled(boolean mtomEnabled) |
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) |
void |
setPortName(QName port) |
void |
setProperties(Map<String,Object> properties) |
void |
setPublishedEndpointUrl(String url) |
void |
setSchemaLocations(List<String> sc) |
void |
setServiceClass(Class<?> cls) |
void |
setServiceClass(Object instance) |
void |
setServiceClass(String type) |
void |
setServiceFactoryBean(Object serviceFactoryBean) |
void |
setServiceName(QName service) |
void |
setServiceNameString(String service) |
void |
setSetDefaultBus(boolean isSetDefaultBus) |
void |
setSkipFaultLogging(boolean skipFaultLogging) |
protected void |
setSkipPayloadMessagePartCheck(boolean skipPayloadMessagePartCheck) |
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) |
void |
setWrapped(boolean wrapped) |
void |
setWrappedStyle(Boolean wrapped) |
void |
setWsdlURL(String url) |
protected void |
updateEndpointUri(String endpointUri) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, 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 QName getServiceName()
public QName getPortName()
public void setPortName(QName port)
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 isInOut()
public void setInOut(boolean inOut)
public boolean isWrapped()
public void setWrapped(boolean wrapped)
public Boolean getWrappedStyle()
public void setWrappedStyle(Boolean wrapped)
public void setAllowStreaming(Boolean b)
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 setSetDefaultBus(boolean isSetDefaultBus)
public boolean isSetDefaultBus()
public void setLoggingFeatureEnabled(boolean loggingFeatureEnabled)
public boolean isLoggingFeatureEnabled()
public int getLoggingSizeLimit()
public void setLoggingSizeLimit(int loggingSizeLimit)
protected boolean isSkipPayloadMessagePartCheck()
protected 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
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 CxfEndpointConfigurer getCxfEndpointConfigurer()
public void setCxfEndpointConfigurer(CxfEndpointConfigurer configurer)
public long getContinuationTimeout()
public void setContinuationTimeout(long continuationTimeout)
Apache Camel