org.onebusaway.transit_data_federation.impl.realtime.orbcad
Class AbstractOrbcadRecordSource

java.lang.Object
  org.onebusaway.transit_data_federation.impl.realtime.orbcad.AbstractOrbcadRecordSource

Direct Known Subclasses:

OrbcadRecordFtpSource, OrbcadRecordHttpSource

@ManagedResource(value="org.onebusaway.transit_data_federation.impl.realtime.orbcad:name=OrbcadRecordFtpSource")
public abstract class AbstractOrbcadRecordSource
extends Object

Nested Class Summary

protected class	AbstractOrbcadRecordSource.AvlRefreshTask
protected class	AbstractOrbcadRecordSource.RecordHandler

Field Summary

protected List<String>	_agencyIds
protected ScheduledExecutorService	_executor

Constructor Summary

AbstractOrbcadRecordSource()

Method Summary

int	getRecordsTotal() JMX Attributes
int	getRecordsValid()
int	getRecordsWithoutBlockId()
int	getRecordsWithoutBlockIdInGraph()
int	getRecordsWithoutServiceDate()
int	getRecordWithoutScheduleDeviation()
protected abstract void	handleRefresh()
void	setAgencyId(String agencyId)
void	setAgencyIds(List<String> agencyIds)
void	setBlockCalendarService(BlockCalendarService blockCalendarService)
void	setBlockIdMappingFile(File blockIdMappingFile)
void	setRefreshInterval(int refreshIntervalInSeconds)
void	setScheduledBlockLocationService(ScheduledBlockLocationService scheduledBlockLocationService)
protected void	setup() Protected Methods
void	setVehicleLocationListener(VehicleLocationListener vehicleLocationListener)
protected void	start() Setup and Teardown
protected void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

_executor

protected ScheduledExecutorService _executor

_agencyIds

protected List<String> _agencyIds

Constructor Detail

AbstractOrbcadRecordSource

public AbstractOrbcadRecordSource()

Method Detail

setRefreshInterval

public void setRefreshInterval(int refreshIntervalInSeconds)

setAgencyId

public void setAgencyId(String agencyId)

setAgencyIds

public void setAgencyIds(List<String> agencyIds)

setBlockIdMappingFile

public void setBlockIdMappingFile(File blockIdMappingFile)

setVehicleLocationListener

public void setVehicleLocationListener(VehicleLocationListener vehicleLocationListener)

setBlockCalendarService

public void setBlockCalendarService(BlockCalendarService blockCalendarService)

setScheduledBlockLocationService

public void setScheduledBlockLocationService(ScheduledBlockLocationService scheduledBlockLocationService)

getRecordsTotal

@ManagedAttribute
public int getRecordsTotal()

JMX Attributes

getRecordWithoutScheduleDeviation

@ManagedAttribute
public int getRecordWithoutScheduleDeviation()

getRecordsWithoutBlockId

@ManagedAttribute
public int getRecordsWithoutBlockId()

getRecordsWithoutBlockIdInGraph

@ManagedAttribute
public int getRecordsWithoutBlockIdInGraph()

getRecordsWithoutServiceDate

@ManagedAttribute
public int getRecordsWithoutServiceDate()

getRecordsValid

@ManagedAttribute
public int getRecordsValid()

start

protected void start()
              throws SocketException,
                     IOException

Setup and Teardown

Throws:

SocketException

IOException

stop

protected void stop()
             throws IOException

Throws:

IOException

setup

protected void setup()

Protected Methods

handleRefresh

protected abstract void handleRefresh()
                               throws IOException

Throws:

IOException