com.serotonin.mango.rt.dataSource.pachube

Class PachubeDataSourceRT

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

com.serotonin.mango.rt.dataSource.pachube.PachubeDataSourceRT

All Implemented Interfaces:

TimeoutClient, com.serotonin.util.ILifecycle

public class PachubeDataSourceRT
extends PollingDataSource

Field Summary

Fields

Modifier and Type	Field and Description
static int	DATA_RETRIEVAL_FAILURE_EVENT
static java.lang.String	HEADER_API_KEY
private org.apache.commons.httpclient.HttpClient	httpClient
(package private) org.apache.commons.logging.Log	log
static int	PARSE_EXCEPTION_EVENT
static int	POINT_WRITE_EXCEPTION_EVENT
(package private) java.text.SimpleDateFormat	sdf
(package private) PachubeDataSourceVO	vo

Fields inherited from class com.serotonin.mango.rt.dataSource.PollingDataSource

dataPoints, pointListChanged

Fields inherited from class com.serotonin.mango.rt.dataSource.DataSourceRT

addedChangedPoints, ATTR_DISCONNECTED_KEY, ATTR_UNRELIABLE_KEY, pointListChangeLock, removedPoints

Constructor Summary

Constructors

Constructor and Description
PachubeDataSourceRT(PachubeDataSourceVO vo)

Method Summary

Modifier and Type	Method and Description
void	addDataPoint(DataPointRT dataPoint)
static org.apache.commons.httpclient.HttpClient	createHttpClient(int timeoutSeconds, int retries)
protected void	doPoll(long time)
void	forcePointRead(DataPointRT dataPoint)
static java.util.Map<java.lang.String,PachubeValue>	getData(org.apache.commons.httpclient.HttpClient client, int feedId, java.lang.String apiKey)
protected void	pollFeed(int feedId, java.util.List<DataPointRT> points, long time)
void	removeDataPoint(DataPointRT dataPoint)
void	setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)

Methods inherited from class com.serotonin.mango.rt.dataSource.PollingDataSource

beginPolling, joinTermination, scheduleTimeout, setPollingPeriod, terminate, updateChangedPoints

Methods inherited from class com.serotonin.mango.rt.dataSource.DataSourceRT

getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, initialize, raiseEvent, relinquish, returnToNormal, setPersistentData

Methods inherited from class java.lang.Object

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

Field Detail

DATA_RETRIEVAL_FAILURE_EVENT

public static final int DATA_RETRIEVAL_FAILURE_EVENT

See Also:

Constant Field Values

PARSE_EXCEPTION_EVENT

public static final int PARSE_EXCEPTION_EVENT

See Also:

Constant Field Values

POINT_WRITE_EXCEPTION_EVENT

public static final int POINT_WRITE_EXCEPTION_EVENT

See Also:

Constant Field Values

HEADER_API_KEY

public static final java.lang.String HEADER_API_KEY

See Also:

Constant Field Values

log

final org.apache.commons.logging.Log log

vo

final PachubeDataSourceVO vo

httpClient

private final org.apache.commons.httpclient.HttpClient httpClient

sdf

final java.text.SimpleDateFormat sdf

Constructor Detail

PachubeDataSourceRT

public PachubeDataSourceRT(PachubeDataSourceVO vo)

Method Detail

createHttpClient

public static org.apache.commons.httpclient.HttpClient createHttpClient(int timeoutSeconds,
                                                                        int retries)

addDataPoint

public void addDataPoint(DataPointRT dataPoint)

Overrides:

addDataPoint in class DataSourceRT

removeDataPoint

public void removeDataPoint(DataPointRT dataPoint)

Overrides:

removeDataPoint in class DataSourceRT

forcePointRead

public void forcePointRead(DataPointRT dataPoint)

Overrides:

forcePointRead in class DataSourceRT

doPoll

protected void doPoll(long time)

Specified by:

doPoll in class PollingDataSource

pollFeed

protected void pollFeed(int feedId,
                        java.util.List<DataPointRT> points,
                        long time)

getData

public static java.util.Map<java.lang.String,PachubeValue> getData(org.apache.commons.httpclient.HttpClient client,
                                                                   int feedId,
                                                                   java.lang.String apiKey)
                                                            throws com.serotonin.web.i18n.LocalizableException

Throws:

com.serotonin.web.i18n.LocalizableException

setPointValue

public void setPointValue(DataPointRT dataPoint,
                          PointValueTime valueTime,
                          SetPointSource source)

Specified by:

setPointValue in class DataSourceRT