org.jacorb.poa

Class RequestQueue

java.lang.Object

org.jacorb.poa.RequestQueue

All Implemented Interfaces:

Configurable

public class RequestQueue
extends Object
implements Configurable

This class manages a queue of ServerRequest objects.

Author:

Reimo Tiedemann, FU Berlin

Constructor Summary

Constructors

Constructor and Description
RequestQueue()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	add(ServerRequest request) Adds a request to this queue.
protected void	addRequestQueueListener(RequestQueueListener listener) Adds the request queue listener.
void	configure(Configuration myConfiguration)
protected StringPair[]	deliverContent() Deliver content.
protected ServerRequest	getFirst() Used by the RequestController - gets the first element
protected boolean	isEmpty() Used by the RequestController - checks if is empty.
protected ServerRequest	removeFirst() Used by the RequestController - removes the first.
protected ServerRequest	removeLast() Used by the RequestController - removes the last.
protected void	removeRequestQueueListener(RequestQueueListener listener) Removes the request queue listener.
protected int	size() Size.

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestQueue

public RequestQueue()

Method Detail

configure

public void configure(Configuration myConfiguration)
               throws ConfigurationException

Specified by:

configure in interface Configurable

Throws:

ConfigurationException

add

protected void add(ServerRequest request)
            throws ResourceLimitReachedException

Adds a request to this queue. The properties jacorb.poa.queue_{min,max,wait} specify what happens when the queue is full, i.e. when it already contains queue_max requests. If queue_wait is off, then this method does not add the request and throws a ResourceLimitReachedException. If queue_wait is on, then this method blocks until no more than queue_min requests are in the queue; it then adds the request, and returns.

Parameters:

request - the request

Throws:

ResourceLimitReachedException - the resource limit reached exception

addRequestQueueListener

protected void addRequestQueueListener(RequestQueueListener listener)

Adds the request queue listener.

Parameters:

listener - the listener

deliverContent

protected StringPair[] deliverContent()

Deliver content.

Returns:

the string pair[]

getFirst

protected ServerRequest getFirst()

Used by the RequestController - gets the first element

Returns:

the first

isEmpty

protected boolean isEmpty()

Used by the RequestController - checks if is empty.

Returns:

true, if is empty

removeFirst

protected ServerRequest removeFirst()

Used by the RequestController - removes the first.

Returns:

the server request

removeLast

protected ServerRequest removeLast()

Used by the RequestController - removes the last.

Returns:

the server request

removeRequestQueueListener

protected void removeRequestQueueListener(RequestQueueListener listener)

Removes the request queue listener.

Parameters:

listener - the listener

size

protected int size()

Size.

Returns:

the int