|
|||||||||||
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.ContinuousConsumerInstance
ContinuousConsumerInstances 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 | |
ContinuousConsumerInstance(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)
Constructs a ContinuousConsumerInstance. |
Method Summary | |
void |
addProducer(org.edg.info.system.ServletConnection connection)
Adds the Producer URL to the Consumer List and starts executing it necessary. |
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)
DOCUMENT ME! |
Message |
getCurrentMessageInFastQueue()
|
Message |
getCurrentMessageInSlowQueue()
|
Message[] |
getMessagesInFastQueue()
|
Message[] |
getMessagesInSlowQueue()
|
org.glite.rgma.system.ProducerTableEntryList |
getProducerTableEntryList()
|
boolean |
isExecuting()
DOCUMENT ME! |
void |
removeProducer(org.edg.info.system.ServletConnection sc)
removeProducer will remove the producer from connections and halt any messages that are still being sent to it. |
void |
setProducerConnections(java.util.Vector servletConnections)
DOCUMENT ME! |
boolean |
updateRegistry(long currentTime,
boolean registryDown)
DOCUMENT ME! |
Methods inherited from class org.edg.info.ConsumerInstance |
abort, canPop, count, getClientHostName, getLastPopTimeMillis, getNumTuplesInStore, getQuery, getQueryProperties, getTableNames, hasAborted, incCompletedExecutes, pop, pop, setClientHostName, start, start |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public ContinuousConsumerInstance(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 statement.servletURL
- The servlet's URL.connectionId
- Consumer connection ID.terminationInterval
- Termination interval.cFlags
- Consumer flags (CONTINUOUS, OLD etc)streamingServer
- Reference to the StreamingServer.timeoutThread
- Thread used for start(long).consumerConfig
- TODO
org.glite.rgma.system.RGMAException
- Thrown by init()
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.RGMAUserException
- DOCUMENT ME!public void addProducer(org.edg.info.system.ServletConnection connection)
connection
- the SerlvetConnection Object of the Producer.
org.glite.rgma.system.RGMAException
- if this Instance Object has been closed.public void destroy()
ConsumerInstance
destroy
in class ConsumerInstance
org.edg.info.InstanceBase#destroy()
public void removeProducer(org.edg.info.system.ServletConnection sc)
XXX-AC: any synchronization needed? I don't think so.
sc
- Servlet connectionpublic void flushQueue(java.lang.String queueName, java.lang.String host)
flushQueue
in class ConsumerInstance
queueName
- DOCUMENT ME!host
- DOCUMENT ME!public void setProducerConnections(java.util.Vector servletConnections)
setProducerConnections
in class ConsumerInstance
servletConnections
- DOCUMENT ME!public boolean updateRegistry(long currentTime, boolean registryDown) throws org.glite.rgma.system.RGMAException, org.glite.rgma.system.RemoteException
updateRegistry
in class InstanceBase
currentTime
- DOCUMENT ME!registryDown
- DOCUMENT ME!
org.glite.rgma.system.RGMAException
- DOCUMENT ME!
org.glite.rgma.system.RemoteException
- DOCUMENT ME!public org.glite.rgma.system.ProducerTableEntryList getProducerTableEntryList()
getProducerTableEntryList
in class ConsumerInstance
public Message[] getMessagesInFastQueue()
getMessagesInFastQueue
in class ConsumerInstance
public Message[] getMessagesInSlowQueue()
getMessagesInSlowQueue
in class ConsumerInstance
public Message getCurrentMessageInFastQueue()
getCurrentMessageInFastQueue
in class ConsumerInstance
public Message getCurrentMessageInSlowQueue()
getCurrentMessageInSlowQueue
in class ConsumerInstance
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |