|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.edg.info.InstanceBase
org.edg.info.ArchiverInstance
Class is used to provide an Archiving service. This operates by periodically sucking in tuples using a Consumer and then re-publishing the data to a Producer. The producer is either a LatestProducer or DataBaseProducer (the type is user defined). Note: The ArchiverInstance can't extend Declarable as the Archiver is not registered and so the supertype's close() method will not work as expected.
Nested Class Summary | |
class |
ArchiverInstance.ArchiverThread
Gets tuples from the Consumer and inserts them into the Insertable. |
Field Summary |
Fields inherited from class org.edg.info.InstanceBase |
DEFAULT_TERMINATION_INTERVAL_MS, s_maxTerminationInterval, s_minTerminationInterval |
Constructor Summary | |
ArchiverInstance(int connectionId,
int insertableConnectionId,
java.net.URL insertableServletURL,
long terminationInterval,
java.net.URL schemaServletLocation,
org.glite.rgma.system.ProducerProperties producerProperties)
Creates a new ArchiverInstance using a defined Insertable Object to archive tuples. |
Method Summary | |
void |
declareTable(java.lang.String tableName,
java.lang.String predicate,
int hrpSec)
Attempts to declare the table using the Insertable Object. |
java.util.Hashtable |
getArchiverThreads()
|
java.lang.String |
getClientHostName()
|
int |
getHistoryRetentionPeriod(java.lang.String tableName)
|
int |
getPrimaryProducerId()
|
java.lang.String |
getPrimaryProducerURL()
|
java.lang.String |
getProducerType()
|
void |
setClientHostName(java.lang.String hostName)
Sets the hostname of the client (that contacted the resource). |
void |
setTerminationInterval(long terminationInterval)
Deprecated. |
void |
showSignOfLife()
Updates the last contact time for all the Consumer Objects and for the Producer. |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public ArchiverInstance(int connectionId, int insertableConnectionId, java.net.URL insertableServletURL, long terminationInterval, java.net.URL schemaServletLocation, org.glite.rgma.system.ProducerProperties producerProperties) throws org.glite.rgma.system.RGMAInternalException, org.glite.rgma.system.RGMAUserException
connectionId
- insertableConnectionId
- insertableServletURL
- terminationInterval
-
org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAInternalException
org.glite.rgma.system.RGMAUserException
Method Detail |
public final void setTerminationInterval(long terminationInterval) throws org.glite.rgma.system.RGMAInternalException, org.glite.rgma.system.RGMAUserException
setTerminationInterval
in class InstanceBase
terminationInterval
- the termination interval to be set.
org.glite.rgma.system.RGMAInternalException
- If the Producer cannot be contacted
org.glite.rgma.system.RGMAUserException
- If the terminationInterval is <= 0.public final void declareTable(java.lang.String tableName, java.lang.String predicate, int hrpSec) throws org.glite.rgma.system.RGMAUserException, org.glite.rgma.system.RGMAInternalException
org.glite.rgma.system.RGMAUserException
org.glite.rgma.system.RGMAInternalException
public final void showSignOfLife() throws org.glite.rgma.system.RGMAException
showSignOfLife
in class InstanceBase
org.glite.rgma.system.RGMAException
- DOCUMENT ME!public final int getHistoryRetentionPeriod(java.lang.String tableName) throws org.glite.rgma.system.RGMAUserException, org.glite.rgma.system.RGMAInternalException
tableName
-
org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAUserException
org.glite.rgma.system.RGMAInternalException
public int getPrimaryProducerId()
public java.lang.String getPrimaryProducerURL()
public java.util.Hashtable getArchiverThreads()
public java.lang.String getProducerType()
public void setClientHostName(java.lang.String hostName)
public java.lang.String getClientHostName()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |