org.apache.streams.gplus.provider

Class AbstractGPlusProvider

java.lang.Object

org.apache.streams.gplus.provider.AbstractGPlusProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

Direct Known Subclasses:

GPlusUserActivityProvider, GPlusUserDataProvider

public abstract class AbstractGPlusProvider
extends Object
implements StreamsProvider

Provider that creates a GPlus client and will run task that queue data to an outing queue.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected com.google.api.client.googleapis.auth.oauth2.GoogleCredential	credential
protected com.google.api.services.plus.Plus	plus
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
AbstractGPlusProvider()
AbstractGPlusProvider(GPlusConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
protected com.google.api.services.plus.Plus	createPlusClient()
GPlusConfiguration	getConfig()
protected abstract Runnable	getDataCollector(org.apache.streams.util.api.requests.backoff.BackOffStrategy strategy, BlockingQueue<StreamsDatum> queue, com.google.api.services.plus.Plus plus, UserInfo userInfo)
String	getId()
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(GPlusConfiguration config)
void	setDefaultAfterDate(org.joda.time.DateTime defaultAfterDate) Set and overwrite the default after date that was read from teh configuration file.
void	setDefaultBeforeDate(org.joda.time.DateTime defaultBeforeDate) Set and overwrite the default before date that was read from the configuration file.
void	setUserInfoWithAfterDate(Map<String,org.joda.time.DateTime> usersAndAfterDates) Set and overwrite user into from the configuration file.
void	setUserInfoWithDefaultDates(Set<String> userIds) Sets and overwrite the user info from the configuaration file.
void	startStream()

Methods inherited from class java.lang.Object

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

Field Detail

STREAMS_ID

public static final String STREAMS_ID

See Also:

Constant Field Values

credential

protected com.google.api.client.googleapis.auth.oauth2.GoogleCredential credential

plus

protected com.google.api.services.plus.Plus plus

Constructor Detail

AbstractGPlusProvider

public AbstractGPlusProvider()

AbstractGPlusProvider

public AbstractGPlusProvider(GPlusConfiguration config)

Method Detail

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

getDataCollector

protected abstract Runnable getDataCollector(org.apache.streams.util.api.requests.backoff.BackOffStrategy strategy,
                                             BlockingQueue<StreamsDatum> queue,
                                             com.google.api.services.plus.Plus plus,
                                             UserInfo userInfo)

getId

public String getId()

Specified by:

getId in interface StreamsOperation

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

createPlusClient

protected com.google.api.services.plus.Plus createPlusClient()
                                                      throws IOException,
                                                             GeneralSecurityException

Throws:

IOException

GeneralSecurityException

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

getConfig

public GPlusConfiguration getConfig()

setConfig

public void setConfig(GPlusConfiguration config)

setDefaultBeforeDate

public void setDefaultBeforeDate(org.joda.time.DateTime defaultBeforeDate)

Set and overwrite the default before date that was read from the configuration file.

Parameters:

defaultBeforeDate - defaultBeforeDate

setDefaultAfterDate

public void setDefaultAfterDate(org.joda.time.DateTime defaultAfterDate)

Set and overwrite the default after date that was read from teh configuration file.

Parameters:

defaultAfterDate - defaultAfterDate

setUserInfoWithDefaultDates

public void setUserInfoWithDefaultDates(Set<String> userIds)

Sets and overwrite the user info from the configuaration file. Uses the defaults before and after dates.

Parameters:

userIds - userIds

setUserInfoWithAfterDate

public void setUserInfoWithAfterDate(Map<String,org.joda.time.DateTime> usersAndAfterDates)

Set and overwrite user into from the configuration file. Only sets after date.

Parameters:

usersAndAfterDates - usersAndAfterDates

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider