|
|||||||||||
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.ConsumerInstance
org.edg.info.OneTimeConsumerInstance
OneTimeConsumerInstances only ever need to contact one publisher in order to answer a query. The registry will return a list of alternative publishers that the OTCI can use, and the instance will try to identify the one that is "closest". If it fails to contact the closest publisher when the query is run, then the next closest will be used.
Field Summary |
Fields inherited from class org.edg.info.InstanceBase |
DEFAULT_TERMINATION_INTERVAL_MS, s_maxTerminationInterval, s_minTerminationInterval |
Constructor Summary | |
OneTimeConsumerInstance(java.lang.String selectStmt,
java.net.URL servletURL,
int connectionId,
long terminationInterval,
int cFlags,
StreamingServer streamingServer,
TimeoutThread timeoutThread,
org.glite.rgma.services.config.ConsumerConfig consumerConfig)
Creates a new OneTimeConsumerInstance object. |
Method Summary | |
void |
destroy()
XXX-AC: note, this is called from a syncrhonized block in the instanceTracker. |
void |
flushQueue(java.lang.String queueName,
java.lang.String host)
|
org.glite.rgma.system.ProducerTableEntryList |
getProducerTableEntryList()
|
void |
incCompletedExecutes()
Increments the number of completed executes. |
boolean |
isExecuting()
Returns the current status of the executing threads. |
void |
setProducerConnections(java.util.Vector servletConnections)
Sets the list of producer connections for this Consumer to contact and sets isGlobalQuery to false . |
Methods inherited from class org.edg.info.ConsumerInstance |
abort, canPop, count, getClientHostName, getCurrentMessageInFastQueue, getCurrentMessageInSlowQueue, getLastPopTimeMillis, getMessagesInFastQueue, getMessagesInSlowQueue, getNumTuplesInStore, getQuery, getQueryProperties, getTableNames, hasAborted, pop, pop, setClientHostName, start, start |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public OneTimeConsumerInstance(java.lang.String selectStmt, java.net.URL servletURL, int connectionId, long terminationInterval, int cFlags, StreamingServer streamingServer, TimeoutThread timeoutThread, org.glite.rgma.services.config.ConsumerConfig consumerConfig) throws org.glite.rgma.system.RGMAInternalException, org.glite.rgma.system.RGMAUserException
selectStmt
- SQL SELECT query.servletURL
- Consumer URL.connectionId
- Consumer ID.terminationInterval
- Termination interval (in ms).cFlags
- Query type flags.streamingServer
- Reference to StreamingServer.timeoutThread
- Reference to TimeoutThread.consumerConfig
- Consumer static configuration.
org.glite.rgma.system.RGMAException
org.glite.rgma.system.RGMAInternalException
org.glite.rgma.system.RGMAUserException
Method Detail |
public boolean isExecuting() throws org.glite.rgma.system.RGMAUserException
isExecuting
in class ConsumerInstance
org.glite.rgma.system.RGMAException
- if the API has been closed or is disconnected.
org.glite.rgma.system.RGMAUserException
public void incCompletedExecutes()
incCompletedExecutes
in class ConsumerInstance
public void flushQueue(java.lang.String queueName, java.lang.String host)
flushQueue
in class ConsumerInstance
queueName
- host
- public void destroy()
ConsumerInstance
destroy
in class ConsumerInstance
org.edg.info.InstanceBase#destroy().
public void setProducerConnections(java.util.Vector servletConnections)
ConsumerInstance
false
.
setProducerConnections
in class ConsumerInstance
servletConnections
- Vector of ServletConnection objects.public org.glite.rgma.system.ProducerTableEntryList getProducerTableEntryList()
getProducerTableEntryList
in class ConsumerInstance
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |