org.edg.info
Class OnDemandProducerInstance.ExecuteThread

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.edg.info.OnDemandProducerInstance.ExecuteThread
All Implemented Interfaces:
java.lang.Runnable
Enclosing class:
OnDemandProducerInstance

public class OnDemandProducerInstance.ExecuteThread
extends java.lang.Thread

Thread used to execute a single one-time query on this producer.


Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
OnDemandProducerInstance.ExecuteThread(java.lang.String select, org.glite.rgma.system.ResourceEndpoint consumer, org.glite.rgma.system.StreamingProperties streamingProps, int timeoutSec, java.lang.String threadUID)
          Creates a new ExecuteThread to stream data to the specified consumer.
 
Method Summary
 void run()
          Reads data from user code (using execute) and streams to streaming server.
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

OnDemandProducerInstance.ExecuteThread

public OnDemandProducerInstance.ExecuteThread(java.lang.String select,
                                              org.glite.rgma.system.ResourceEndpoint consumer,
                                              org.glite.rgma.system.StreamingProperties streamingProps,
                                              int timeoutSec,
                                              java.lang.String threadUID)
                                       throws org.glite.rgma.system.RGMAInternalException
Creates a new ExecuteThread to stream data to the specified consumer.

Parameters:
select - SQL SELECT statement.
consumer - Consumer making query.
streamingProps - Streaming server to stream to.
timeoutSec - Query timeout in seconds.
threadUID - Unique ID of thread.
Throws:
org.glite.rgma.system.RGMAInternalException - If a connection to the streaming server can't be created.
Method Detail

run

public void run()
Reads data from user code (using execute) and streams to streaming server.