@ManagedResource(description="Managed Twitter Endpoint") @UriEndpoint(scheme="twitter", title="Twitter", syntax="twitter:kind", consumerClass=TwitterConsumer.class, label="api,social") public class TwitterEndpointPolling extends org.apache.camel.impl.DefaultPollingEndpoint implements TwitterEndpoint
Constructor and Description |
---|
TwitterEndpointPolling(String uri,
TwitterComponent component,
TwitterConfiguration properties) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
Integer |
getCount() |
EndpointType |
getEndpointType() |
String |
getKeywords() |
String |
getLang() |
String |
getLocations() |
Integer |
getNumberOfPages() |
TwitterConfiguration |
getProperties() |
long |
getSinceId() |
boolean |
isFilterOld() |
boolean |
isSingleton() |
void |
setCount(Integer count) |
void |
setDelay(long delay)
Milliseconds before the next poll.
|
void |
setFilterOld(boolean filterOld) |
void |
setKeywords(String keywords) |
void |
setLang(String lang) |
void |
setLocations(String locations) |
void |
setNumberOfPages(Integer numberOfPages) |
void |
setProperties(TwitterConfiguration properties) |
void |
setSinceId(long sinceId) |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public TwitterEndpointPolling(String uri, TwitterComponent component, TwitterConfiguration properties)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
createConsumer
in class org.apache.camel.impl.DefaultPollingEndpoint
Exception
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public TwitterConfiguration getProperties()
getProperties
in interface TwitterEndpoint
public void setProperties(TwitterConfiguration properties)
@ManagedAttribute public String getKeywords()
@ManagedAttribute public void setKeywords(String keywords)
@ManagedAttribute public String getLocations()
@ManagedAttribute public void setLocations(String locations)
@ManagedAttribute public void setFilterOld(boolean filterOld)
@ManagedAttribute public boolean isFilterOld()
@ManagedAttribute public void setSinceId(long sinceId)
@ManagedAttribute public long getSinceId()
@ManagedAttribute public void setLang(String lang)
@ManagedAttribute public String getLang()
@ManagedAttribute public void setCount(Integer count)
@ManagedAttribute public Integer getCount()
@ManagedAttribute public void setNumberOfPages(Integer numberOfPages)
@ManagedAttribute public Integer getNumberOfPages()
public EndpointType getEndpointType()
getEndpointType
in interface TwitterEndpoint
public void setDelay(long delay)
setDelay
in class org.apache.camel.impl.ScheduledPollEndpoint
Apache Camel