org.apache.camel.component.twitter
Class TwitterEndpointDirect

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by org.apache.camel.component.direct.DirectEndpoint
              extended by org.apache.camel.component.twitter.TwitterEndpointDirect
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

@UriEndpoint(scheme="twitter",
             consumerClass=Twitter4JConsumer.class)
public class TwitterEndpointDirect
extends org.apache.camel.component.direct.DirectEndpoint
implements TwitterEndpoint

Twitter direct endpoint


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
TwitterEndpointDirect(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()
           
 org.apache.camel.ExchangePattern getExchangePattern()
           
 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.component.direct.DirectEndpoint
addConsumer, getConsumer, getKey, getTimeout, hasConsumer, isBlock, removeConsumer, setBlock, setTimeout
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, 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

TwitterEndpointDirect

public TwitterEndpointDirect(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.component.direct.DirectEndpoint
Throws:
Exception

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.direct.DirectEndpoint
Throws:
Exception

isSingleton

@ManagedAttribute
public boolean isSingleton()
Specified by:
isSingleton in interface org.apache.camel.IsSingleton
Overrides:
isSingleton in class org.apache.camel.component.direct.DirectEndpoint

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

getExchangePattern

public org.apache.camel.ExchangePattern getExchangePattern()
Overrides:
getExchangePattern in class org.apache.camel.impl.DefaultEndpoint

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


Apache Camel