org.apache.camel.component.cxf
Class CxfEndpoint

java.lang.Object
  org.apache.camel.impl.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.cxf.CxfEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, HasId, HeaderFilterStrategyAware

Direct Known Subclasses:

CxfBlueprintEndpoint, CxfSpringEndpoint

public class CxfEndpoint
extends DefaultEndpoint
implements HeaderFilterStrategyAware, Service

Defines the CXF Endpoint. It contains a list of properties for CXF endpoint including DataFormat, CxfBinding, and HeaderFilterStrategy. The default DataFormat mode is DataFormat.POJO.

Version:

Constructor Summary

CxfEndpoint(String remaining, CamelContext context)

CxfEndpoint(String remaining, CxfComponent cxfComponent)

Method Summary

protected org.apache.cxf.frontend.ClientFactoryBean	createClientFactoryBean() Create a client factory bean object without serviceClass interface.
protected org.apache.cxf.frontend.ClientProxyFactoryBean	createClientFactoryBean(Class<?> cls) Create a client factory bean object.
Consumer	createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
Producer	createProducer() Creates a new producer which is used send messages into the endpoint
protected org.apache.cxf.Bus	doGetBus()
protected void	doStart()
protected void	doStop()
String	getAddress()
org.apache.cxf.Bus	getBus()
CxfBinding	getCxfBinding()
DataFormat	getDataFormat()
String	getDefaultOperationName()
String	getDefaultOperationNamespace()
HeaderFilterStrategy	getHeaderFilterStrategy() Gets the header filter strategy used
String	getPortName()
Map<String,Object>	getProperties()
String	getPublishedEndpointUrl()
String	getServiceClass()
String	getServiceName()
Boolean	getWrappedStyle()
String	getWsdlURL()
boolean	isInOut()
boolean	isLoggingFeatureEnabled()
boolean	isMtomEnabled()
boolean	isSetDefaultBus()
boolean	isSingleton() Whether this class supports being singleton or not.
protected boolean	isSkipPayloadMessagePartCheck()
boolean	isWrapped()
void	setAddress(String address)
void	setBus(org.apache.cxf.Bus bus)
void	setCxfBinding(CxfBinding cxfBinding)
void	setDataFormat(DataFormat format)
void	setDefaultOperationName(String name)
void	setDefaultOperationNamespace(String namespace)
void	setHeaderFilterStrategy(HeaderFilterStrategy headerFilterStrategy) Sets the header filter strategy to use
void	setInOut(boolean inOut)
void	setLoggingFeatureEnabled(boolean loggingFeatureEnabled)
void	setMtomEnabled(boolean mtomEnabled)
void	setPortName(String port)
void	setProperties(Map<String,Object> properties)
void	setPublishedEndpointUrl(String url)
void	setServiceClass(Object instance)
void	setServiceClass(String className)
void	setServiceName(String service)
void	setSetDefaultBus(boolean isSetDefaultBus)
protected void	setSkipPayloadMessagePartCheck(boolean skipPayloadMessagePartCheck)
protected void	setupClientFactoryBean(org.apache.cxf.frontend.ClientFactoryBean factoryBean)
protected void	setupClientFactoryBean(org.apache.cxf.frontend.ClientProxyFactoryBean factoryBean, Class<?> cls) Populate a client factory bean
protected void	setupServerFactoryBean(org.apache.cxf.frontend.ServerFactoryBean sfb, Class<?> cls) Populate server factory bean
void	setWrapped(boolean wrapped)
void	setWrappedStyle(Boolean wrapped)
void	setWsdlURL(String url)
protected void	updateEndpointUri(String endpointUri)

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureProperties, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, sanitizeUri, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

Methods inherited from class org.apache.camel.impl.ServiceSupport

addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

CxfEndpoint

public CxfEndpoint(String remaining,
                   CxfComponent cxfComponent)

CxfEndpoint

public CxfEndpoint(String remaining,
                   CamelContext context)

Method Detail

updateEndpointUri

protected void updateEndpointUri(String endpointUri)

createProducer

public Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

Creates a new producer which is used send messages into the endpoint

Specified by:

createProducer in interface Endpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown

createConsumer

public Consumer createConsumer(Processor processor)
                        throws Exception

Description copied from interface: Endpoint

Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Specified by:

createConsumer in interface Endpoint

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

isSingleton

public boolean isSingleton()

Description copied from interface: IsSingleton

Whether this class supports being singleton or not.

Specified by:

isSingleton in interface IsSingleton

Returns:

true to be a single shared instance, false to create new instances.

setupServerFactoryBean

protected void setupServerFactoryBean(org.apache.cxf.frontend.ServerFactoryBean sfb,
                                      Class<?> cls)

Populate server factory bean

createClientFactoryBean

protected org.apache.cxf.frontend.ClientProxyFactoryBean createClientFactoryBean(Class<?> cls)
                                                                          throws CamelException

Create a client factory bean object. Notice that the serviceClass must be an interface.

Throws:

CamelException

createClientFactoryBean

protected org.apache.cxf.frontend.ClientFactoryBean createClientFactoryBean()

Create a client factory bean object without serviceClass interface.

doGetBus

protected org.apache.cxf.Bus doGetBus()

setupClientFactoryBean

protected void setupClientFactoryBean(org.apache.cxf.frontend.ClientProxyFactoryBean factoryBean,
                                      Class<?> cls)

Populate a client factory bean

setupClientFactoryBean

protected void setupClientFactoryBean(org.apache.cxf.frontend.ClientFactoryBean factoryBean)

getDataFormat

public DataFormat getDataFormat()

setDataFormat

public void setDataFormat(DataFormat format)

getPublishedEndpointUrl

public String getPublishedEndpointUrl()

setPublishedEndpointUrl

public void setPublishedEndpointUrl(String url)

getWsdlURL

public String getWsdlURL()

setWsdlURL

public void setWsdlURL(String url)

getServiceClass

public String getServiceClass()

setServiceClass

public void setServiceClass(String className)

setServiceClass

public void setServiceClass(Object instance)

setServiceName

public void setServiceName(String service)

getServiceName

public String getServiceName()

getPortName

public String getPortName()

setPortName

public void setPortName(String port)

getDefaultOperationName

public String getDefaultOperationName()

setDefaultOperationName

public void setDefaultOperationName(String name)

getDefaultOperationNamespace

public String getDefaultOperationNamespace()

setDefaultOperationNamespace

public void setDefaultOperationNamespace(String namespace)

isInOut

public boolean isInOut()

setInOut

public void setInOut(boolean inOut)

isWrapped

public boolean isWrapped()

setWrapped

public void setWrapped(boolean wrapped)

getWrappedStyle

public Boolean getWrappedStyle()

setWrappedStyle

public void setWrappedStyle(Boolean wrapped)

setCxfBinding

public void setCxfBinding(CxfBinding cxfBinding)

getCxfBinding

public CxfBinding getCxfBinding()

setHeaderFilterStrategy

public void setHeaderFilterStrategy(HeaderFilterStrategy headerFilterStrategy)

Description copied from interface: HeaderFilterStrategyAware

Sets the header filter strategy to use

Specified by:

setHeaderFilterStrategy in interface HeaderFilterStrategyAware

Parameters:

headerFilterStrategy - the strategy

getHeaderFilterStrategy

public HeaderFilterStrategy getHeaderFilterStrategy()

Description copied from interface: HeaderFilterStrategyAware

Gets the header filter strategy used

Specified by:

getHeaderFilterStrategy in interface HeaderFilterStrategyAware

Returns:

the strategy

setBus

public void setBus(org.apache.cxf.Bus bus)

getBus

public org.apache.cxf.Bus getBus()

setSetDefaultBus

public void setSetDefaultBus(boolean isSetDefaultBus)

isSetDefaultBus

public boolean isSetDefaultBus()

setLoggingFeatureEnabled

public void setLoggingFeatureEnabled(boolean loggingFeatureEnabled)

isLoggingFeatureEnabled

public boolean isLoggingFeatureEnabled()

isSkipPayloadMessagePartCheck

protected boolean isSkipPayloadMessagePartCheck()

setSkipPayloadMessagePartCheck

protected void setSkipPayloadMessagePartCheck(boolean skipPayloadMessagePartCheck)

getProperties

public Map<String,Object> getProperties()

setProperties

public void setProperties(Map<String,Object> properties)

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class DefaultEndpoint

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class DefaultEndpoint

Throws:

Exception

setAddress

public void setAddress(String address)

getAddress

public String getAddress()

setMtomEnabled

public void setMtomEnabled(boolean mtomEnabled)

isMtomEnabled

public boolean isMtomEnabled()