org.opentripplanner.updater.stoptime

Class PollingStoptimeUpdater

java.lang.Object

org.opentripplanner.updater.PollingGraphUpdater

org.opentripplanner.updater.stoptime.PollingStoptimeUpdater

All Implemented Interfaces:

GraphUpdater, JsonConfigurable

public class PollingStoptimeUpdater
extends PollingGraphUpdater

Update OTP stop time tables from some (realtime) source Usage example ('rt' name is an example) in file 'Graph.properties':

 rt.type = stop-time-updater
 rt.frequencySec = 60
 rt.sourceType = gtfs-http
 rt.url = http://host.tld/path
 rt.feedId = TA
 

Field Summary

Fields inherited from class org.opentripplanner.updater.PollingGraphUpdater

frequencySec

Constructor Summary

Constructors

Constructor and Description
PollingStoptimeUpdater()

Method Summary

Modifier and Type	Method and Description
void	configurePolling(Graph graph, com.fasterxml.jackson.databind.JsonNode config) Mirrors GraphUpdater.configure method.
void	runPolling() Repeatedly makes blocking calls to an UpdateStreamer to retrieve new stop time updates, and applies those updates to the graph.
void	setGraphUpdaterManager(GraphUpdaterManager updaterManager) Graph updaters must be aware of their manager to be able to execute GraphWriterRunnables.
void	setup() Here the updater can be initialized.
void	teardown() Here the updater can cleanup after itself.
String	toString()

Methods inherited from class org.opentripplanner.updater.PollingGraphUpdater

configure, run

Methods inherited from class java.lang.Object

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

Constructor Detail

PollingStoptimeUpdater

public PollingStoptimeUpdater()

Method Detail

setGraphUpdaterManager

public void setGraphUpdaterManager(GraphUpdaterManager updaterManager)

Description copied from interface: GraphUpdater

Graph updaters must be aware of their manager to be able to execute GraphWriterRunnables. GraphUpdaterConfigurator should take care of calling this function.

Parameters:

updaterManager - is the parent updater manager

See Also:

GraphWriterRunnable, GraphUpdaterManager.execute

configurePolling

public void configurePolling(Graph graph,
                             com.fasterxml.jackson.databind.JsonNode config)
                      throws Exception

Description copied from class: PollingGraphUpdater

Mirrors GraphUpdater.configure method.

Specified by:

configurePolling in class PollingGraphUpdater

Throws:

Exception

setup

public void setup()
           throws InterruptedException,
                  ExecutionException

Description copied from interface: GraphUpdater

Here the updater can be initialized. If it throws, the updater won't be started (i.e. the run method won't be called).

Throws:

InterruptedException

ExecutionException

runPolling

public void runPolling()

Repeatedly makes blocking calls to an UpdateStreamer to retrieve new stop time updates, and applies those updates to the graph.

Specified by:

runPolling in class PollingGraphUpdater

teardown

public void teardown()

Description copied from interface: GraphUpdater

Here the updater can cleanup after itself.

toString

public String toString()

Overrides:

toString in class Object