org.apache.camel.component.gae.task
Class GTaskEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.impl.ScheduledPollEndpoint
org.apache.camel.impl.DefaultPollingEndpoint
org.apache.camel.component.http.HttpEndpoint
org.apache.camel.component.servlet.ServletEndpoint
org.apache.camel.component.gae.task.GTaskEndpoint
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware, OutboundBindingSupport<GTaskEndpoint,com.google.appengine.api.taskqueue.TaskOptions,Void>, 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 GTaskEndpoint
- extends org.apache.camel.component.servlet.ServletEndpoint
- implements OutboundBindingSupport<GTaskEndpoint,com.google.appengine.api.taskqueue.TaskOptions,Void>
Represents a Google App Engine Task Queueing endpoint.
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary |
GTaskEndpoint(String endpointUri,
org.apache.camel.component.servlet.ServletComponent component,
URI httpUri,
org.apache.commons.httpclient.params.HttpClientParams params,
org.apache.commons.httpclient.HttpConnectionManager httpConnectionManager,
org.apache.camel.component.http.HttpClientConfigurer clientConfigurer)
|
Methods inherited from class org.apache.camel.component.servlet.ServletEndpoint |
createConsumer, getServletName, isLenientProperties, setServletName |
Methods inherited from class org.apache.camel.component.http.HttpEndpoint |
connect, createHttpClient, createPollingConsumer, disconnect, getAuthMethodPriority, getClientParams, getHeaderFilterStrategy, getHttpClientConfigurer, getHttpConnectionManager, getHttpUri, getPath, getPort, getProtocol, getProxyHost, getProxyPort, isBridgeEndpoint, isChunked, isDisableStreamCache, isMatchOnUriPrefix, isSingleton, isThrowExceptionOnFailure, isTraceEnabled, isTransferException, setAuthMethodPriority, setBinding, setBridgeEndpoint, setChunked, setClientParams, setDisableStreamCache, setHeaderFilterStrategy, setHttpClientConfigurer, setHttpConnectionManager, setHttpUri, setMatchOnUriPrefix, setProxyHost, setProxyPort, setThrowExceptionOnFailure, setTraceEnabled, setTransferException |
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint |
configureProperties |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, doStart, doStop, equals, getCamelContext, getComponent, 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 interface org.apache.camel.Service |
start, stop |
GTaskEndpoint
public GTaskEndpoint(String endpointUri,
org.apache.camel.component.servlet.ServletComponent component,
URI httpUri,
org.apache.commons.httpclient.params.HttpClientParams params,
org.apache.commons.httpclient.HttpConnectionManager httpConnectionManager,
org.apache.camel.component.http.HttpClientConfigurer clientConfigurer)
throws URISyntaxException
- Throws:
URISyntaxException
getOutboundBinding
public OutboundBinding<GTaskEndpoint,com.google.appengine.api.taskqueue.TaskOptions,Void> getOutboundBinding()
- Specified by:
getOutboundBinding
in interface OutboundBindingSupport<GTaskEndpoint,com.google.appengine.api.taskqueue.TaskOptions,Void>
setOutboundBinding
public void setOutboundBinding(OutboundBinding<GTaskEndpoint,com.google.appengine.api.taskqueue.TaskOptions,Void> outboundBinding)
- Specified by:
setOutboundBinding
in interface OutboundBindingSupport<GTaskEndpoint,com.google.appengine.api.taskqueue.TaskOptions,Void>
getInboundBinding
public InboundBinding<GTaskEndpoint,javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse> getInboundBinding()
setInboundBinding
public void setInboundBinding(InboundBinding<GTaskEndpoint,javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse> inboundBinding)
getBinding
public org.apache.camel.component.http.HttpBinding getBinding()
- Proxies the
HttpBinding
returned by super#getBinding()
with a dynamic proxy. The proxy's invocation handler further delegates to
InboundBinding.readRequest(org.apache.camel.Endpoint, Exchange, Object)
.
- Overrides:
getBinding
in class org.apache.camel.component.http.HttpEndpoint
- Returns:
- proxied
HttpBinding
.
getWorkerRoot
public String getWorkerRoot()
- See Also:
setWorkerRoot(String)
setWorkerRoot
public void setWorkerRoot(String workerRoot)
- Sets the web hook path root.
- Parameters:
workerRoot
- the assumed web hook path root. The default is
worker
. The servlet handling the callback from
the task queueing service should have a /worker/*
servlet mapping in this case. If another servlet mapping is
used it must be set here accordingly.
getQueue
public com.google.appengine.api.taskqueue.Queue getQueue()
setQueue
public void setQueue(com.google.appengine.api.taskqueue.Queue queue)
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Specified by:
createProducer
in interface org.apache.camel.Endpoint
- Overrides:
createProducer
in class org.apache.camel.component.servlet.ServletEndpoint
- Throws:
Exception
Apache CAMEL