org.edg.info
Class LatestProducerInstance

java.lang.Object
  extended byorg.edg.info.InstanceBase
      extended byorg.edg.info.DeclarableInstance
          extended byorg.edg.info.InsertableInstance
              extended byorg.edg.info.CleanableInstance
                  extended byorg.edg.info.LatestProducerInstance

public class LatestProducerInstance
extends CleanableInstance


Nested Class Summary
 
Nested classes inherited from class org.edg.info.CleanableInstance
CleanableInstance.CleanUpThread
 
Field Summary
 
Fields inherited from class org.edg.info.CleanableInstance
s_dbAdminDriver, s_dbAdminPassword, s_dbAdminURL, s_dbAdminUserName
 
Fields inherited from class org.edg.info.InstanceBase
DEFAULT_TERMINATION_INTERVAL_MS, s_maxTerminationInterval, s_minTerminationInterval
 
Constructor Summary
LatestProducerInstance(org.edg.info.system.Registry registry, org.edg.info.system.Schema schema, org.glite.rgma.services.config.PrimaryProducerConfig config, org.edg.info.system.ServletConnection thisProducer, long terminationInterval, org.glite.rgma.system.Storage storage)
          Creates a LatestProducer setting up a default internal database.
 
Methods inherited from class org.edg.info.CleanableInstance
abort, declareTable, declareTable, destroy, execute, execute, undeclareTable
 
Methods inherited from class org.edg.info.InsertableInstance
canDestroy, declareAsArchiver, getConsumerConnections, getHistoryRetentionPeriod, getLastStreamDurationMillis, getLatestRetentionPeriod, getMaxBufferSize, getMinRetentionPeriod, getQueueTracker, getRetentionPeriods, getStreamDurationMillis, insert, isAutoInsertTimestampEnabled, setAutoInsertTimestamp, setMinRetentionPeriod, startStreaming, stopStreaming, streamTuples
 
Methods inherited from class org.edg.info.DeclarableInstance
declareTable, getClientHostName, getProducerType, setClientHostName, updateRegistry
 
Methods inherited from class org.edg.info.InstanceBase
disconnect, getCreationTimeMillis, getLastRegistryUpdateTimeMillis, getRegistryUpdateIntervalMillis, getResourceId, getStatus, getTerminationInterval, getTerminationIntervalMillis, getUserLastContactTimeMillis, isDestroyed, isTupleCheckingEnabled, notifyRegistrationThread, reconnect, setCloseCalled, setDestroyed, setRegistrationThread, setTerminationInterval, showSignOfLife, updateLastContactTime, wasCloseCalled
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LatestProducerInstance

public LatestProducerInstance(org.edg.info.system.Registry registry,
                              org.edg.info.system.Schema schema,
                              org.glite.rgma.services.config.PrimaryProducerConfig config,
                              org.edg.info.system.ServletConnection thisProducer,
                              long terminationInterval,
                              org.glite.rgma.system.Storage storage)
                       throws org.glite.rgma.system.RGMAException
Creates a LatestProducer setting up a default internal database.

Parameters:
registry - API to access Registry.
schema - API to access Schema.
thisProducer -
terminationInterval -
storage - Storage medium for tuples.
Throws:
org.glite.rgma.system.RGMAException