org.apache.streams.gmail.provider

Class GMailProvider

java.lang.Object

org.apache.streams.gmail.provider.GMailProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

public class GMailProvider
extends Object
implements StreamsProvider, Serializable

GMailProvider collects messages from GMail.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected DatumStatusCounter	countersCurrent
protected DatumStatusCounter	countersTotal
protected com.googlecode.gmail4j.javamail.ImapGmailClient	imapClient
protected BlockingQueue	inQueue
protected Queue<StreamsDatum>	providerQueue
protected com.googlecode.gmail4j.GmailClient	rssClient
static String	STREAMS_ID
protected Future	task

Constructor Summary

Constructors

Constructor and Description
GMailProvider()
GMailProvider(Class klass)
GMailProvider(GMailConfiguration config)
GMailProvider(GMailConfiguration config, Class klass)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
GMailConfiguration	getConfig()
String	getId()
BlockingQueue<Object>	getInQueue()
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(GMailConfiguration config)
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

inQueue

protected BlockingQueue inQueue

providerQueue

protected volatile Queue<StreamsDatum> providerQueue

task

protected Future task

rssClient

protected com.googlecode.gmail4j.GmailClient rssClient

imapClient

protected com.googlecode.gmail4j.javamail.ImapGmailClient imapClient

countersTotal

protected DatumStatusCounter countersTotal

countersCurrent

protected DatumStatusCounter countersCurrent

Constructor Detail

GMailProvider

public GMailProvider()

GMailProvider

public GMailProvider(GMailConfiguration config)

GMailProvider

public GMailProvider(Class klass)

GMailProvider

public GMailProvider(GMailConfiguration config,
                     Class klass)

Method Detail

getConfig

public GMailConfiguration getConfig()

setConfig

public void setConfig(GMailConfiguration config)

getInQueue

public BlockingQueue<Object> getInQueue()

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

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation