|
|||||||||||
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.RegistryInstance
RegistryInstance is an object that supports the RegistryServlet. It offers package-level methods that correspond to Registry API methods. Synchronization has been added to prevent the Registry write operations from interfering with a Replica update.
Field Summary |
Fields inherited from class org.edg.info.InstanceBase |
DEFAULT_TERMINATION_INTERVAL_MS, s_maxTerminationInterval, s_minTerminationInterval |
Constructor Summary | |
RegistryInstance(org.glite.rgma.services.config.RegistryConfig registryConfig)
Creates a new RegistryInstance object. |
Method Summary | |
void |
addReplica(Replica replica)
Delegates the replica update to the ReplicaManager. |
void |
destroy()
This is called when the servlet is destroyed. |
void |
flushQueue(java.lang.String queueName,
java.lang.String host)
|
Message |
getCurrentMessageInFastQueue()
|
Message |
getCurrentMessageInMediumQueue()
|
Message |
getCurrentMessageInSlowQueue()
|
org.glite.rgma.system.ResultSet |
getFixedColumnData(java.lang.String producerURL,
int connectionId,
java.lang.String tableName)
Returns the column names, values and types of those columns a producer has declared as fixed. |
org.edg.info.system.RelevantPublisherInfo |
getInfoForOneTimeQuery(java.lang.String query,
int queryType)
Returns information that is needed for planning a latest/history query. |
org.glite.rgma.system.ProducerTableEntryList |
getMatchingProducersForTables(java.lang.String[] tables,
java.lang.String predicate,
boolean complete)
DOCUMENT ME! |
Message[] |
getMessagesInFastQueue()
|
Message[] |
getMessagesInMediumQueue()
|
Message[] |
getMessagesInSlowQueue()
|
org.glite.rgma.system.ResultSet |
getProducerInfo(java.lang.String url,
int connectionId)
Returns the column names of a producers table. |
java.util.Vector |
getRelevantProducers(java.lang.String tableName,
java.lang.String predicate,
int flags)
Returns producers that are relevant to a Consumer's query. |
long |
getReplicationIntervalMillis()
|
org.edg.info.system.ServletConnection |
getServletConnection(java.lang.String servletURL,
int connectionId)
This method was added to aid testing, in future a better mechanism should be adopted. |
java.lang.String |
getVDBName()
|
boolean |
isReplicating()
|
java.util.Vector |
registerContinuousQuery(java.lang.String url,
int connectionId,
java.lang.String query,
int queryType,
long clientTimeStamp,
long terminationTime)
Registers consumer with a CONTINUOUS query in database and returns list of relevant producers (can't return republishers, as there is a block at the moment in flags.matches()). |
void |
registerProducerTable(java.lang.String producerURL,
int producerId,
java.lang.String tableName,
java.lang.String predicate,
int flags,
long clientTimeStamp,
long terminationTime)
Registers a producer view. |
void |
setConsumerTerminationTime(java.lang.String consumerURL,
int connectionId,
long clientTimeStamp,
long terminationTime)
Sets the termination time for a consumer. |
void |
setProducerTerminationTime(java.lang.String producerURL,
int connectionId,
long clientTimeStamp,
long terminationTime)
Sets the termination time for a producer. |
void |
unRegisterConsumer(java.lang.String url,
int connectionId)
Unregisters the Consumer. |
void |
unRegisterProducer(java.lang.String url,
int connectionId)
Attempts to unregister all tables belonging to a Producer. |
void |
unRegisterProducerTable(java.lang.String url,
int connectionId,
java.lang.String tableName)
Attempts to un registry a Producer table. |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public RegistryInstance(org.glite.rgma.services.config.RegistryConfig registryConfig) throws org.glite.rgma.system.RGMAException
Method Detail |
public void setConsumerTerminationTime(java.lang.String consumerURL, int connectionId, long clientTimeStamp, long terminationTime) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public org.glite.rgma.system.ResultSet getFixedColumnData(java.lang.String producerURL, int connectionId, java.lang.String tableName) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public org.edg.info.system.RelevantPublisherInfo getInfoForOneTimeQuery(java.lang.String query, int queryType) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public org.glite.rgma.system.ResultSet getProducerInfo(java.lang.String url, int connectionId) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public org.glite.rgma.system.ProducerTableEntryList getMatchingProducersForTables(java.lang.String[] tables, java.lang.String predicate, boolean complete) throws org.glite.rgma.system.RGMAException
tables
- DOCUMENT ME!predicate
- DOCUMENT ME!complete
- DOCUMENT ME!
org.glite.rgma.system.RGMAException
- DOCUMENT ME!public void setProducerTerminationTime(java.lang.String producerURL, int connectionId, long clientTimeStamp, long terminationTime) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public java.util.Vector getRelevantProducers(java.lang.String tableName, java.lang.String predicate, int flags) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public org.edg.info.system.ServletConnection getServletConnection(java.lang.String servletURL, int connectionId) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public void addReplica(Replica replica) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public void destroy()
public java.util.Vector registerContinuousQuery(java.lang.String url, int connectionId, java.lang.String query, int queryType, long clientTimeStamp, long terminationTime) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public void registerProducerTable(java.lang.String producerURL, int producerId, java.lang.String tableName, java.lang.String predicate, int flags, long clientTimeStamp, long terminationTime) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public void unRegisterConsumer(java.lang.String url, int connectionId) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public void unRegisterProducer(java.lang.String url, int connectionId) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public void unRegisterProducerTable(java.lang.String url, int connectionId, java.lang.String tableName) throws org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAException
public void flushQueue(java.lang.String queueName, java.lang.String host)
queueName
- host
- public java.lang.String getVDBName()
public boolean isReplicating()
public long getReplicationIntervalMillis()
public Message getCurrentMessageInFastQueue()
Messenger.getCopyOfCurrentMessageInFastQueue()
public Message[] getMessagesInFastQueue()
Messenger.getCopyOfFastMessageQueue()
public Message getCurrentMessageInSlowQueue()
Messenger.getCopyOfCurrentMessageInSlowQueue()
public Message[] getMessagesInSlowQueue()
Messenger.getCopyOfSlowMessageQueue()
public Message getCurrentMessageInMediumQueue()
public Message[] getMessagesInMediumQueue()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |