org.apache.streams.sysomos.provider

Class SysomosHeartbeatStream

java.lang.Object

org.apache.streams.sysomos.provider.SysomosHeartbeatStream

All Implemented Interfaces:

Runnable

public class SysomosHeartbeatStream
extends Object
implements Runnable

Provides a Runnable query mechanism for grabbing documents from the Sysomos API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	SysomosHeartbeatStream.QueryResult

Constructor Summary

Constructors

Constructor and Description
SysomosHeartbeatStream(SysomosProvider provider, String heartbeatId)
SysomosHeartbeatStream(SysomosProvider provider, String heartbeatId, org.joda.time.DateTime beforeTime, org.joda.time.DateTime afterTime) SysomosHeartbeatStream constructor.
SysomosHeartbeatStream(SysomosProvider provider, String heartbeatId, String documentId) SysomosHeartbeatStream constructor.
SysomosHeartbeatStream(SysomosProvider provider, String heartbeatId, org.apache.streams.sysomos.provider.SysomosHeartbeatStream.OperatingMode mode) SysomosHeartbeatStream constructor.

Method Summary

Modifier and Type	Method and Description
protected BeatApi.BeatResponse	executeApiRequest()
protected void	executeRun()
protected SysomosHeartbeatStream.QueryResult	queryApi()
void	run()
protected void	shutdown()
protected void	sleep()
protected void	updateOffset(SysomosHeartbeatStream.QueryResult result)
protected void	updateState(SysomosHeartbeatStream.QueryResult result, String mostCurrentId, int totalDocCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

SysomosHeartbeatStream

public SysomosHeartbeatStream(SysomosProvider provider,
                              String heartbeatId)

SysomosHeartbeatStream

public SysomosHeartbeatStream(SysomosProvider provider,
                              String heartbeatId,
                              org.joda.time.DateTime beforeTime,
                              org.joda.time.DateTime afterTime)

SysomosHeartbeatStream constructor.

Parameters:

provider - SysomosProvider

heartbeatId - heartbeatId

beforeTime - DateTime

afterTime - DateTime

SysomosHeartbeatStream

public SysomosHeartbeatStream(SysomosProvider provider,
                              String heartbeatId,
                              String documentId)

SysomosHeartbeatStream constructor.

Parameters:

provider - SysomosProvider

heartbeatId - heartbeatId

documentId - last documentId

SysomosHeartbeatStream

public SysomosHeartbeatStream(SysomosProvider provider,
                              String heartbeatId,
                              org.apache.streams.sysomos.provider.SysomosHeartbeatStream.OperatingMode mode)

SysomosHeartbeatStream constructor.

Parameters:

provider - SysomosProvider

heartbeatId - heartbeatId

mode - OperatingMode

Method Detail

run

public void run()

Specified by:

run in interface Runnable

executeRun

protected void executeRun()

updateState

protected void updateState(SysomosHeartbeatStream.QueryResult result,
                           String mostCurrentId,
                           int totalDocCount)

updateOffset

protected void updateOffset(SysomosHeartbeatStream.QueryResult result)

sleep

protected void sleep()

queryApi

protected SysomosHeartbeatStream.QueryResult queryApi()

executeApiRequest

protected BeatApi.BeatResponse executeApiRequest()

shutdown

protected void shutdown()