org.apache.camel.component.twitter
Class TwitterEndpointPolling

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.twitter.TwitterEndpointPolling

All Implemented Interfaces:

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

@ManagedResource(description="Managed Twitter Endpoint")
@UriEndpoint(scheme="twitter",
             consumerClass=Twitter4JConsumer.class)
public class TwitterEndpointPolling
extends org.apache.camel.impl.DefaultPollingEndpoint
implements TwitterEndpoint

Twitter polling endpoint

Field Summary

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

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

Constructor Summary

TwitterEndpointPolling(String uri, TwitterComponent component, TwitterConfiguration properties)

Method Summary

org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
String	getCamelId()
String	getCamelManagementName()
Integer	getCount()
String	getDate()
EndpointType	getEndpointType()
String	getEndpointUri()
String	getKeywords()
String	getLang()
String	getLocations()
Integer	getNumberOfPages()
TwitterConfiguration	getProperties()
long	getSinceId()
String	getState()
boolean	isFilterOld()
boolean	isSingleton()
void	setCount(Integer count)
void	setDate(String date)
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)
void	shutdown()

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

configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties

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

configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString

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

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

configureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointConfiguration, getEndpointKey, isLenientProperties, setCamelContext

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

TwitterEndpointPolling

public TwitterEndpointPolling(String uri,
                              TwitterComponent component,
                              TwitterConfiguration properties)

Method Detail

createConsumer

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

Specified by:

createConsumer in interface org.apache.camel.Endpoint

Overrides:

createConsumer in class org.apache.camel.impl.DefaultPollingEndpoint

Throws:

Exception

createProducer

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

Specified by:

createProducer in interface org.apache.camel.Endpoint

Throws:

Exception

isSingleton

@ManagedAttribute
public boolean isSingleton()

Specified by:

isSingleton in interface org.apache.camel.IsSingleton

getProperties

public TwitterConfiguration getProperties()

Specified by:

getProperties in interface TwitterEndpoint

setProperties

public void setProperties(TwitterConfiguration properties)

getCamelId

@ManagedAttribute(description="Camel ID")
public String getCamelId()

getCamelManagementName

@ManagedAttribute(description="Camel ManagementName")
public String getCamelManagementName()

getEndpointUri

@ManagedAttribute(description="Endpoint Uri",
                  mask=true)
public String getEndpointUri()

Specified by:

getEndpointUri in interface org.apache.camel.Endpoint

Overrides:

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

getState

@ManagedAttribute(description="Service State")
public String getState()

getKeywords

@ManagedAttribute
public String getKeywords()

setKeywords

@ManagedAttribute
public void setKeywords(String keywords)

getLocations

@ManagedAttribute
public String getLocations()

setLocations

@ManagedAttribute
public void setLocations(String locations)

setFilterOld

@ManagedAttribute
public void setFilterOld(boolean filterOld)

isFilterOld

@ManagedAttribute
public boolean isFilterOld()

setDate

@ManagedAttribute
public void setDate(String date)

getDate

@ManagedAttribute
public String getDate()

setSinceId

@ManagedAttribute
public void setSinceId(long sinceId)

getSinceId

@ManagedAttribute
public long getSinceId()

setLang

@ManagedAttribute
public void setLang(String lang)

getLang

@ManagedAttribute
public String getLang()

setCount

@ManagedAttribute
public void setCount(Integer count)

getCount

@ManagedAttribute
public Integer getCount()

setNumberOfPages

@ManagedAttribute
public void setNumberOfPages(Integer numberOfPages)

getNumberOfPages

@ManagedAttribute
public Integer getNumberOfPages()

getEndpointType

public EndpointType getEndpointType()

Specified by:

getEndpointType in interface TwitterEndpoint

shutdown

public void shutdown()
              throws Exception

Specified by:

shutdown in interface org.apache.camel.ShutdownableService

Overrides:

shutdown in class org.apache.camel.support.ServiceSupport

Throws:

Exception