org.apache.streams.facebook.provider

Class FacebookFriendUpdatesProvider

java.lang.Object

org.apache.streams.facebook.provider.FacebookFriendUpdatesProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

public class FacebookFriendUpdatesProvider
extends Object
implements StreamsProvider, Serializable

FacebookFriendUpdatesProvider provides updates from friend feed.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.joda.time.DateTime	end
protected ExecutorService	executor
protected Iterator<String[]>	idsBatches
protected ReadWriteLock	lock
protected Queue<StreamsDatum>	providerQueue
protected AtomicBoolean	running
protected org.joda.time.DateTime	start

Constructor Summary

Constructors

Constructor and Description
FacebookFriendUpdatesProvider() FacebookFriendUpdatesProvider constructor - resolves FacebookUserInformationConfiguration from JVM 'facebook'.
FacebookFriendUpdatesProvider(Class klass) FacebookFriendUpdatesProvider constructor.
FacebookFriendUpdatesProvider(FacebookUserstreamConfiguration config) FacebookFriendUpdatesProvider constructor - uses supplied FacebookUserstreamConfiguration.
FacebookFriendUpdatesProvider(FacebookUserstreamConfiguration config, Class klass) FacebookFriendUpdatesProvider constructor.

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
FacebookUserstreamConfiguration	getConfig()
protected facebook4j.Facebook	getFacebookClient()
String	getId()
Queue<StreamsDatum>	getProviderQueue()
boolean	isRunning()
void	prepare(Object configurationObject)
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
void	setConfig(FacebookUserstreamConfiguration config)
void	startStream()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

lock

protected final ReadWriteLock lock

providerQueue

protected volatile Queue<StreamsDatum> providerQueue

idsBatches

protected Iterator<String[]> idsBatches

executor

protected ExecutorService executor

start

protected org.joda.time.DateTime start

end

protected org.joda.time.DateTime end

running

protected final AtomicBoolean running

Constructor Detail

FacebookFriendUpdatesProvider

public FacebookFriendUpdatesProvider()

FacebookFriendUpdatesProvider constructor - resolves FacebookUserInformationConfiguration from JVM 'facebook'.

FacebookFriendUpdatesProvider

public FacebookFriendUpdatesProvider(FacebookUserstreamConfiguration config)

FacebookFriendUpdatesProvider constructor - uses supplied FacebookUserstreamConfiguration.

FacebookFriendUpdatesProvider

public FacebookFriendUpdatesProvider(Class klass)

FacebookFriendUpdatesProvider constructor. uses supplied output Class. resolves FacebookUserInformationConfiguration from JVM 'facebook.

FacebookFriendUpdatesProvider

public FacebookFriendUpdatesProvider(FacebookUserstreamConfiguration config,
                                     Class klass)

FacebookFriendUpdatesProvider constructor. uses supplied FacebookUserstreamConfiguration. uses supplied output Class.

Method Detail

getConfig

public FacebookUserstreamConfiguration getConfig()

setConfig

public void setConfig(FacebookUserstreamConfiguration config)

getProviderQueue

public Queue<StreamsDatum> getProviderQueue()

getId

public String getId()

Specified by:

getId in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

readNew

public StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime start,
                                  org.joda.time.DateTime end)

Specified by:

readRange in interface StreamsProvider

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

getFacebookClient

protected facebook4j.Facebook getFacebookClient()

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation