wt.router
Class RoundRobinRouter

java.lang.Object
  wt.router.RoundRobinRouter

All Implemented Interfaces:

Serializable

public class RoundRobinRouter

extends Object

implements Serializable

Supported API: false

Extendable: false

See Also:

Serialized Form

Field Summary

private static String	CLASSNAME
private int	currentQueueNumber
private static String	RESOURCE

Constructor Summary

RoundRobinRouter()

Method Summary

private void	initQueues(int routerNum, int nQueues)
private boolean	isEmpty(ProcessingQueue pq)
static RoundRobinRouter	newRoundRobinRouter(String routerName, int routerNum, int nQueues) Supported API: false
void	postToQueue(RouterIfc router, WTPrincipal princ, String t_method, String t_class, Class[] arg_types, Serializable[] args) Supported API: false

Methods inherited from class java.lang.Object

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

Field Detail

RESOURCE

private static final String RESOURCE

See Also:

Constant Field Values

CLASSNAME

private static final String CLASSNAME

currentQueueNumber

private int currentQueueNumber

Constructor Detail

RoundRobinRouter

public RoundRobinRouter()

Method Detail

newRoundRobinRouter

public static RoundRobinRouter newRoundRobinRouter(String routerName,
                                                   int routerNum,
                                                   int nQueues)
                                            throws WTException

Supported API: false

Parameters:

routerName -

routerNum -

nQueues -

Returns:

RoundRobinRouter

Throws:

WTException

postToQueue

public void postToQueue(RouterIfc router,
                        WTPrincipal princ,
                        String t_method,
                        String t_class,
                        Class[] arg_types,
                        Serializable[] args)
                 throws WTException

Supported API: false

Parameters:

router -

princ -

t_method -

t_class -

arg_types -

args -

Throws:

WTException

initQueues

private void initQueues(int routerNum,
                        int nQueues)
                 throws WTException

Throws:

WTException

isEmpty

private boolean isEmpty(ProcessingQueue pq)
                 throws WTException

Throws:

WTException