org.apache.camel.component.gae.task
Class GTaskEndpoint

java.lang.Object
  extended by org.apache.camel.impl.DefaultEndpoint
      extended by org.apache.camel.impl.ScheduledPollEndpoint
          extended by org.apache.camel.impl.DefaultPollingEndpoint
              extended by org.apache.camel.component.http.HttpEndpoint
                  extended by org.apache.camel.component.servlet.ServletEndpoint
                      extended by org.apache.camel.component.gae.task.GTaskEndpoint
All Implemented Interfaces:
CamelContextAware, OutboundBindingSupport<GTaskEndpoint,com.google.appengine.api.labs.taskqueue.TaskOptions,Void>, Endpoint, IsSingleton, Service, HasId, HeaderFilterStrategyAware

public class GTaskEndpoint
extends ServletEndpoint
implements OutboundBindingSupport<GTaskEndpoint,com.google.appengine.api.labs.taskqueue.TaskOptions,Void>

Represents a Google App Engine Task Queueing endpoint.


Constructor Summary
GTaskEndpoint(String endpointUri, ServletComponent component, URI httpUri, org.apache.commons.httpclient.params.HttpClientParams params, org.apache.commons.httpclient.HttpConnectionManager httpConnectionManager, HttpClientConfigurer clientConfigurer)
           
 
Method Summary
 Producer createProducer()
          Creates a new producer which is used send messages into the endpoint
 HttpBinding getBinding()
          Proxies the HttpBinding returned by super#getBinding() with a dynamic proxy.
 InboundBinding<GTaskEndpoint,HttpServletRequest,HttpServletResponse> getInboundBinding()
           
 OutboundBinding<GTaskEndpoint,com.google.appengine.api.labs.taskqueue.TaskOptions,Void> getOutboundBinding()
           
 com.google.appengine.api.labs.taskqueue.Queue getQueue()
           
 String getWorkerRoot()
           
 void setInboundBinding(InboundBinding<GTaskEndpoint,HttpServletRequest,HttpServletResponse> inboundBinding)
           
 void setOutboundBinding(OutboundBinding<GTaskEndpoint,com.google.appengine.api.labs.taskqueue.TaskOptions,Void> outboundBinding)
           
 void setQueue(com.google.appengine.api.labs.taskqueue.Queue queue)
           
 void setWorkerRoot(String workerRoot)
          Sets the web hook path root.
 
Methods inherited from class org.apache.camel.component.servlet.ServletEndpoint
createConsumer, getServletName, 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, isLenientProperties, isMatchOnUriPrefix, isSingleton, isThrowExceptionOnFailure, setAuthMethodPriority, setBinding, setBridgeEndpoint, setChunked, setClientParams, setDisableStreamCache, setHeaderFilterStrategy, setHttpClientConfigurer, setHttpConnectionManager, setHttpUri, setMatchOnUriPrefix, setProxyHost, setProxyPort, setThrowExceptionOnFailure
 
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint
configureConsumer, configureProperties, getConsumerProperties, setConsumerProperties
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
createEndpointUri, createExchange, createExchange, createExchange, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, getId, hashCode, isSynchronous, sanitizeUri, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, start, stop, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

GTaskEndpoint

public GTaskEndpoint(String endpointUri,
                     ServletComponent component,
                     URI httpUri,
                     org.apache.commons.httpclient.params.HttpClientParams params,
                     org.apache.commons.httpclient.HttpConnectionManager httpConnectionManager,
                     HttpClientConfigurer clientConfigurer)
              throws URISyntaxException
Throws:
URISyntaxException
Method Detail

getOutboundBinding

public OutboundBinding<GTaskEndpoint,com.google.appengine.api.labs.taskqueue.TaskOptions,Void> getOutboundBinding()
Specified by:
getOutboundBinding in interface OutboundBindingSupport<GTaskEndpoint,com.google.appengine.api.labs.taskqueue.TaskOptions,Void>

setOutboundBinding

public void setOutboundBinding(OutboundBinding<GTaskEndpoint,com.google.appengine.api.labs.taskqueue.TaskOptions,Void> outboundBinding)
Specified by:
setOutboundBinding in interface OutboundBindingSupport<GTaskEndpoint,com.google.appengine.api.labs.taskqueue.TaskOptions,Void>

getInboundBinding

public InboundBinding<GTaskEndpoint,HttpServletRequest,HttpServletResponse> getInboundBinding()

setInboundBinding

public void setInboundBinding(InboundBinding<GTaskEndpoint,HttpServletRequest,HttpServletResponse> inboundBinding)

getBinding

public 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 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.labs.taskqueue.Queue getQueue()

setQueue

public void setQueue(com.google.appengine.api.labs.taskqueue.Queue queue)

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
Overrides:
createProducer in class ServletEndpoint
Returns:
a newly created producer
Throws:
Exception - can be thrown


Apache CAMEL