Package com.inductiveautomation.perspective.gateway.threading

Class PerspectivePollingFuture<V>

java.lang.Object

com.inductiveautomation.ignition.common.lifecycle.AbstractLifecycle

com.inductiveautomation.ignition.common.execution.PollingFuture<V>

com.inductiveautomation.perspective.gateway.threading.PerspectivePollingFuture<V>

All Implemented Interfaces:

Lifecycle

public class PerspectivePollingFuture<V>
extends PollingFuture<V>

Manages a polling task that looks up its rate from a property tree and is reactive to the rate changing.

Nested Class Summary

Nested classes/interfaces inherited from class com.inductiveautomation.ignition.common.execution.PollingFuture

PollingFuture.State

Field Summary

Fields inherited from class com.inductiveautomation.ignition.common.execution.PollingFuture

LOG

Constructor Summary

Constructors

Constructor	Description
PerspectivePollingFuture(PerspectiveContext context, PropertyTree props, String refreshRatePath, long defaultRate, Supplier<CompletableFuture<V>> fetch, BiConsumer<V,Throwable> consumer, String diagnosticId)
PerspectivePollingFuture(ScheduledExecutorService scheduler, ExecutorService executor, PropertyTree props, String refreshRatePath, long defaultRate, Supplier<CompletableFuture<V>> fetch, BiConsumer<V,Throwable> consumer, String diagnosticId)

Method Summary

Modifier and Type	Method	Description
protected long	getInitialRate()	Default implementation returns the rate from the constructor, but provides a place for subclasses to re-define the rate on startup if necessary.
protected long	getRefreshRateFromProps()
protected void	onRefreshRateChange(PropertyTreeChangeEvent event)
protected void	onShutdown()
protected Optional<Long>	parseLong(QualifiedValue qv)

Methods inherited from class com.inductiveautomation.ignition.common.execution.PollingFuture

getRateMillis, onStartup, setRate, submitIfIdle

Methods inherited from class com.inductiveautomation.ignition.common.lifecycle.AbstractLifecycle

isRunning, shutdown, startup

Methods inherited from class java.lang.Object

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

Constructor Details

PerspectivePollingFuture

public PerspectivePollingFuture(PerspectiveContext context,
 PropertyTree props,
 String refreshRatePath,
 long defaultRate,
 Supplier<CompletableFuture<V>> fetch,
 BiConsumer<V,Throwable> consumer,
 String diagnosticId)

PerspectivePollingFuture

public PerspectivePollingFuture(ScheduledExecutorService scheduler,
 ExecutorService executor,
 PropertyTree props,
 String refreshRatePath,
 long defaultRate,
 Supplier<CompletableFuture<V>> fetch,
 BiConsumer<V,Throwable> consumer,
 String diagnosticId)

Method Details

getInitialRate

protected long getInitialRate()

Description copied from class: PollingFuture

Default implementation returns the rate from the constructor, but provides a place for subclasses to re-define the rate on startup if necessary.

Overrides:

getInitialRate in class PollingFuture<V>

onShutdown

protected void onShutdown()

Overrides:

onShutdown in class PollingFuture<V>

onRefreshRateChange

protected void onRefreshRateChange(PropertyTreeChangeEvent event)

getRefreshRateFromProps

protected long getRefreshRateFromProps()

parseLong

protected Optional<Long> parseLong(QualifiedValue qv)