org.globus.wsrf.container
Class ServiceDispatcher

java.lang.Object
  |
  +--org.globus.wsrf.container.ServiceDispatcher

All Implemented Interfaces:

Runnable

public class ServiceDispatcher

extends Object

implements Runnable

Dispatcher reading requests off the socket and putting them into a request queue.

Field Summary

protected AxisEngine	engine
protected int	highWaterMark
protected int	maxThreads
protected int	numThreads
protected ServiceRequestQueue	queue
protected ServiceThreadPool	threadPool

Constructor Summary

ServiceDispatcher(String config)

Method Summary

AxisEngine	getAxisEngine()
ServerSocket	getServerSocket()
boolean	isStopped()
void	run()
void	setServerSocket(ServerSocket serverSocket)
void	setThreads(int numThreads)
void	start(boolean daemon) Start this dispatcher.
void	stop()
void	waitForInit()
void	waitForStop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

queue

protected ServiceRequestQueue queue

threadPool

protected ServiceThreadPool threadPool

numThreads

protected int numThreads

maxThreads

protected int maxThreads

highWaterMark

protected int highWaterMark

engine

protected AxisEngine engine

Constructor Detail

ServiceDispatcher

public ServiceDispatcher(String config)

Method Detail

getAxisEngine

public AxisEngine getAxisEngine()

setServerSocket

public void setServerSocket(ServerSocket serverSocket)

getServerSocket

public ServerSocket getServerSocket()

setThreads

public void setThreads(int numThreads)

waitForInit

public void waitForInit()
                 throws InterruptedException

run

public void run()

Specified by:

run in interface Runnable

waitForStop

public void waitForStop()
                 throws InterruptedException

stop

public void stop()
          throws IOException

isStopped

public boolean isStopped()

start

public void start(boolean daemon)

Start this dispatcher. Spawns a worker thread to listen for HTTP requests.

Parameters:

daemon - a boolean indicating if the thread should be a daemon.