@UriEndpoint(scheme="cxfrs", title="CXF-RS", syntax="cxfrs:beanId:address", consumerClass=CxfRsConsumer.class, label="http,rest") public class CxfRsEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.spi.HeaderFilterStrategyAware, org.apache.camel.Service
Modifier and Type | Class and Description |
---|---|
static class |
CxfRsEndpoint.BindingStyle |
Modifier and Type | Field and Description |
---|---|
protected org.apache.cxf.Bus |
bus |
protected List<Object> |
entityProviders |
protected List<String> |
schemaLocations |
Constructor and Description |
---|
CxfRsEndpoint() |
CxfRsEndpoint(String endpointUri,
org.apache.camel.CamelContext camelContext)
Deprecated.
|
CxfRsEndpoint(String endpointUri,
org.apache.camel.Component component) |
Modifier and Type | Method and Description |
---|---|
void |
addResourceClass(Class<?> resourceClass) |
protected void |
checkBeanType(Object object,
Class<?> clazz) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean |
createJAXRSClientFactoryBean() |
org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean |
createJAXRSClientFactoryBean(String address) |
org.apache.cxf.jaxrs.JAXRSServerFactoryBean |
createJAXRSServerFactoryBean() |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
String |
getAddress() |
String |
getBeanId() |
CxfRsBinding |
getBinding() |
CxfRsEndpoint.BindingStyle |
getBindingStyle() |
org.apache.cxf.Bus |
getBus() |
long |
getContinuationTimeout() |
List<org.apache.cxf.feature.Feature> |
getFeatures() |
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() |
int |
getMaxClientCacheSize() |
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() |
Map<String,String> |
getParameters() |
Map<String,Object> |
getProperties() |
List<?> |
getProviders() |
List<Class<?>> |
getResourceClasses() |
List<String> |
getSchemaLocations() |
boolean |
isHttpClientAPI() |
boolean |
isIgnoreDeleteMethodMessageBody() |
boolean |
isLenientProperties() |
boolean |
isLoggingFeatureEnabled() |
boolean |
isPerformInvocation() |
boolean |
isPropagateContexts() |
boolean |
isSetDefaultBus() |
boolean |
isSingleton() |
boolean |
isSkipFaultLogging() |
boolean |
isThrowExceptionOnFailure() |
protected org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean |
newJAXRSClientFactoryBean() |
protected org.apache.cxf.jaxrs.JAXRSServerFactoryBean |
newJAXRSServerFactoryBean() |
protected String |
resolvePropertyPlaceholders(String str) |
void |
setAddress(String address) |
void |
setBeanId(String beanId) |
void |
setBinding(CxfRsBinding binding) |
void |
setBindingStyle(CxfRsEndpoint.BindingStyle bindingStyle)
See documentation of
CxfRsEndpoint.BindingStyle . |
void |
setBus(org.apache.cxf.Bus bus) |
void |
setContinuationTimeout(long continuationTimeout) |
void |
setFeatures(List<org.apache.cxf.feature.Feature> features) |
void |
setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy strategy) |
void |
setHttpClientAPI(boolean clientAPI) |
void |
setIgnoreDeleteMethodMessageBody(boolean ignoreDeleteMethodMessageBody) |
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) |
void |
setLoggingSizeLimit(int loggingSizeLimit) |
void |
setMaxClientCacheSize(int maxClientCacheSize) |
void |
setModelRef(String ref) |
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 |
setParameters(Map<String,String> param) |
void |
setPerformInvocation(boolean performInvocation) |
void |
setPropagateContexts(boolean propagateContexts) |
void |
setProperties(Map<String,Object> properties) |
void |
setProvider(Object provider) |
void |
setProviders(List<?> providers) |
void |
setResourceClasses(Class<?>... classes) |
void |
setResourceClasses(List<Class<?>> resourceClasses) |
void |
setSchemaLocation(String schema) |
void |
setSchemaLocations(List<String> schemas) |
void |
setSetDefaultBus(boolean isSetDefaultBus) |
void |
setSkipFaultLogging(boolean skipFaultLogging) |
void |
setThrowExceptionOnFailure(boolean throwExceptionOnFailure) |
protected void |
setupCommonFactoryProperties(org.apache.cxf.jaxrs.AbstractJAXRSFactoryBean factory) |
protected void |
setupJAXRSClientFactoryBean(org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean cfb,
String address) |
protected void |
setupJAXRSServerFactoryBean(org.apache.cxf.jaxrs.JAXRSServerFactoryBean sfb) |
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, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, 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 CxfRsEndpoint()
@Deprecated public CxfRsEndpoint(String endpointUri, org.apache.camel.CamelContext camelContext)
public CxfRsEndpoint(String endpointUri, org.apache.camel.Component component)
protected void updateEndpointUri(String endpointUri)
public void setHttpClientAPI(boolean clientAPI)
public boolean isHttpClientAPI()
public boolean isLenientProperties()
isLenientProperties
in interface org.apache.camel.Endpoint
isLenientProperties
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.spi.HeaderFilterStrategy getHeaderFilterStrategy()
getHeaderFilterStrategy
in interface org.apache.camel.spi.HeaderFilterStrategyAware
public void setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy strategy)
setHeaderFilterStrategy
in interface org.apache.camel.spi.HeaderFilterStrategyAware
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public void setBinding(CxfRsBinding binding)
public CxfRsBinding getBinding()
public boolean isSkipFaultLogging()
public void setSkipFaultLogging(boolean skipFaultLogging)
protected void setupJAXRSServerFactoryBean(org.apache.cxf.jaxrs.JAXRSServerFactoryBean sfb)
protected void setupJAXRSClientFactoryBean(org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean cfb, String address)
protected void setupCommonFactoryProperties(org.apache.cxf.jaxrs.AbstractJAXRSFactoryBean factory)
protected org.apache.cxf.jaxrs.JAXRSServerFactoryBean newJAXRSServerFactoryBean()
protected org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean newJAXRSClientFactoryBean()
public org.apache.cxf.jaxrs.JAXRSServerFactoryBean createJAXRSServerFactoryBean()
public org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean createJAXRSClientFactoryBean()
public org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean createJAXRSClientFactoryBean(String address)
public void addResourceClass(Class<?> resourceClass)
public void setResourceClasses(Class<?>... classes)
public void setAddress(String address)
public void setModelRef(String ref)
public String getAddress()
public boolean isLoggingFeatureEnabled()
public void setLoggingFeatureEnabled(boolean loggingFeatureEnabled)
public int getLoggingSizeLimit()
public void setLoggingSizeLimit(int loggingSizeLimit)
public boolean isThrowExceptionOnFailure()
public void setThrowExceptionOnFailure(boolean throwExceptionOnFailure)
public void setMaxClientCacheSize(int maxClientCacheSize)
maxClientCacheSize
- the maxClientCacheSize to setpublic int getMaxClientCacheSize()
public void setBus(org.apache.cxf.Bus bus)
public org.apache.cxf.Bus getBus()
public void setSetDefaultBus(boolean isSetDefaultBus)
public boolean isSetDefaultBus()
public boolean isIgnoreDeleteMethodMessageBody()
public void setIgnoreDeleteMethodMessageBody(boolean ignoreDeleteMethodMessageBody)
public CxfRsEndpoint.BindingStyle getBindingStyle()
public List<?> getProviders()
public void setProviders(List<?> providers)
public void setProvider(Object provider)
public void setSchemaLocation(String schema)
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 List<org.apache.cxf.feature.Feature> getFeatures()
public void setFeatures(List<org.apache.cxf.feature.Feature> features)
public void setBindingStyle(CxfRsEndpoint.BindingStyle bindingStyle)
CxfRsEndpoint.BindingStyle
.public String getBeanId()
public void setBeanId(String beanId)
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 long getContinuationTimeout()
public void setContinuationTimeout(long continuationTimeout)
public boolean isPerformInvocation()
public void setPerformInvocation(boolean performInvocation)
public boolean isPropagateContexts()
public void setPropagateContexts(boolean propagateContexts)
Apache Camel