org.edg.info
Class FastStreamProducerInstance

java.lang.Object
  extended byorg.edg.info.InstanceBase
      extended byorg.edg.info.DeclarableInstance
          extended byorg.edg.info.InsertableInstance
              extended byorg.edg.info.FastStreamProducerInstance

public class FastStreamProducerInstance
extends InsertableInstance

Performs same function as StreamProducerInstance, but uses fast SQL INSERT parsing and new faster/more stable streaming.


Field Summary
 
Fields inherited from class org.edg.info.InstanceBase
DEFAULT_TERMINATION_INTERVAL_MS, s_maxTerminationInterval, s_minTerminationInterval
 
Constructor Summary
FastStreamProducerInstance(org.edg.info.system.Registry registry, org.edg.info.system.Schema schema, org.edg.info.system.ServletConnection sc, long terminationInterval, org.glite.rgma.services.config.PrimaryProducerConfig primaryProducerConfig)
          Constructor, which sets up a registry and starts a RegistrationThread.
 
Methods inherited from class org.edg.info.InsertableInstance
canDestroy, declareAsArchiver, declareTable, destroy, 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, undeclareTable, 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

FastStreamProducerInstance

public FastStreamProducerInstance(org.edg.info.system.Registry registry,
                                  org.edg.info.system.Schema schema,
                                  org.edg.info.system.ServletConnection sc,
                                  long terminationInterval,
                                  org.glite.rgma.services.config.PrimaryProducerConfig primaryProducerConfig)
                           throws org.glite.rgma.system.RGMAException
Constructor, which sets up a registry and starts a RegistrationThread.

Parameters:
registry - API to access Registry.
schema - API to access Schema.
sc - Servlet connection
terminationInterval - Termination interval
Throws:
org.glite.rgma.system.RGMAException - Thrown by init()