org.apache.camel.component.cxf
Class CxfEndpoint

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by 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()


Apache CAMEL