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

java.lang.Object
  extended by 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


Copyright © 2011 OneBusAway. All Rights Reserved.