org.edg.info
Class StreamingServer

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.edg.info.StreamingServer
All Implemented Interfaces:
java.lang.Runnable

public class StreamingServer
extends java.lang.Thread

Handles incoming requests to stream from StreamProducers on behalf of all local ConsumerInstances.


Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
StreamingServer()
          Creates a new StreamingServer object.
StreamingServer(InstanceTracker tracker, int streamingPort, java.lang.String serviceURL)
          Constructs a streaming server, listening on port streamingPort, putting data in consumers from tracker.
 
Method Summary
 void addConnection(org.edg.info.system.ServletConnection producerConnection)
          Adds a producer connection.
 StopStreamingRequest getCurrentStopStreamingRequest()
           
 java.lang.Object[] getStopStreamingRequests()
           
 void run()
          Main loop; while the server is active, waits for incoming data and adds it to appropriate QueueManager.
 void terminate()
          Stops the main loop and shuts down all sockets.
 
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

StreamingServer

public StreamingServer()
Creates a new StreamingServer object.


StreamingServer

public StreamingServer(InstanceTracker tracker,
                       int streamingPort,
                       java.lang.String serviceURL)
                throws org.glite.rgma.system.RGMAException
Constructs a streaming server, listening on port streamingPort, putting data in consumers from tracker.

Parameters:
tracker -
streamingPort -
Throws:
org.glite.rgma.system.RGMAException
Method Detail

addConnection

public void addConnection(org.edg.info.system.ServletConnection producerConnection)
Adds a producer connection. The server can now expect to be contacted by producerConnection.getServletURL().

Parameters:
producerConnection -

run

public void run()
Main loop; while the server is active, waits for incoming data and adds it to appropriate QueueManager.


terminate

public void terminate()
Stops the main loop and shuts down all sockets.


getStopStreamingRequests

public java.lang.Object[] getStopStreamingRequests()

getCurrentStopStreamingRequest

public StopStreamingRequest getCurrentStopStreamingRequest()