org.apache.camel.component.ahc
Class AhcEndpoint

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.ahc.AhcEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.spi.HeaderFilterStrategyAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class AhcEndpoint
extends org.apache.camel.impl.DefaultEndpoint
implements org.apache.camel.spi.HeaderFilterStrategyAware

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

AhcEndpoint(String endpointUri, AhcComponent component, URI httpUri)

Method Summary

org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
protected void	doStart()
protected void	doStop()
AhcBinding	getBinding()
com.ning.http.client.AsyncHttpClient	getClient()
com.ning.http.client.AsyncHttpClientConfig	getClientConfig()
AhcComponent	getComponent()
org.apache.camel.spi.HeaderFilterStrategy	getHeaderFilterStrategy()
URI	getHttpUri()
org.apache.camel.util.jsse.SSLContextParameters	getSslContextParameters()
boolean	isBridgeEndpoint()
boolean	isLenientProperties()
boolean	isSingleton()
boolean	isThrowExceptionOnFailure()
boolean	isTransferException()
void	setBinding(AhcBinding binding)
void	setBridgeEndpoint(boolean bridgeEndpoint)
void	setClient(com.ning.http.client.AsyncHttpClient client)
void	setClientConfig(com.ning.http.client.AsyncHttpClientConfig clientConfig)
void	setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
void	setHttpUri(URI httpUri)
void	setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
void	setThrowExceptionOnFailure(boolean throwExceptionOnFailure)
void	setTransferException(boolean transferException)

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

configureConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

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

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, 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

AhcEndpoint

public AhcEndpoint(String endpointUri,
                   AhcComponent component,
                   URI httpUri)

Method Detail

getComponent

public AhcComponent getComponent()

Overrides:

getComponent in class org.apache.camel.impl.DefaultEndpoint

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Specified by:

createProducer in interface org.apache.camel.Endpoint

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Specified by:

createConsumer in interface org.apache.camel.Endpoint

Throws:

Exception

isLenientProperties

public boolean isLenientProperties()

Specified by:

isLenientProperties in interface org.apache.camel.Endpoint

Overrides:

isLenientProperties in class org.apache.camel.impl.DefaultEndpoint

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.apache.camel.IsSingleton

getClient

public com.ning.http.client.AsyncHttpClient getClient()

setClient

public void setClient(com.ning.http.client.AsyncHttpClient client)

getClientConfig

public com.ning.http.client.AsyncHttpClientConfig getClientConfig()

setClientConfig

public void setClientConfig(com.ning.http.client.AsyncHttpClientConfig clientConfig)

getHttpUri

public URI getHttpUri()

setHttpUri

public void setHttpUri(URI httpUri)

getBinding

public AhcBinding getBinding()

setBinding

public void setBinding(AhcBinding binding)

getHeaderFilterStrategy

public org.apache.camel.spi.HeaderFilterStrategy getHeaderFilterStrategy()

Specified by:

getHeaderFilterStrategy in interface org.apache.camel.spi.HeaderFilterStrategyAware

setHeaderFilterStrategy

public void setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)

Specified by:

setHeaderFilterStrategy in interface org.apache.camel.spi.HeaderFilterStrategyAware

isBridgeEndpoint

public boolean isBridgeEndpoint()

setBridgeEndpoint

public void setBridgeEndpoint(boolean bridgeEndpoint)

isThrowExceptionOnFailure

public boolean isThrowExceptionOnFailure()

setThrowExceptionOnFailure

public void setThrowExceptionOnFailure(boolean throwExceptionOnFailure)

isTransferException

public boolean isTransferException()

setTransferException

public void setTransferException(boolean transferException)

getSslContextParameters

public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()

setSslContextParameters

public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.apache.camel.impl.DefaultEndpoint

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.DefaultEndpoint

Throws:

Exception