Class DefaultScheduler

java.lang.Object

com.swiftmq.impl.routing.single.schedule.Scheduler

com.swiftmq.impl.routing.single.schedule.DefaultScheduler

All Implemented Interfaces:

POSchedulerVisitor, DeliveryCallback, com.swiftmq.tools.pipeline.POVisitor

Direct Known Subclasses:

RoundRobinScheduler

public class DefaultScheduler
extends Scheduler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DefaultScheduler.ConnectionEntry

Constructor Summary

Constructors

Constructor	Description
DefaultScheduler(SwiftletContext ctx, String destinationRouter, String queueName)

Method Summary

Modifier and Type	Method	Description
void	addRoute(Route route)
void	close()
protected RoutingConnection	getNextConnection()
int	getNumberConnections()
void	removeRoute(Route route)
void	removeRoutingConnection(RoutingConnection routingConnection)
String	toString()

Methods inherited from class Scheduler

connectionAdded, connectionRemoved, delivered, enqueueClose, getQueueName, visit, visit, visit, visit, visit

Methods inherited from class Object

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

Constructor Details

DefaultScheduler

public DefaultScheduler(SwiftletContext ctx,
 String destinationRouter,
 String queueName)

Method Details

getNextConnection

protected RoutingConnection getNextConnection()

Specified by:

getNextConnection in class Scheduler

addRoute

public void addRoute(Route route)

Specified by:

addRoute in class Scheduler

removeRoute

public void removeRoute(Route route)

Specified by:

removeRoute in class Scheduler

removeRoutingConnection

public void removeRoutingConnection(RoutingConnection routingConnection)

Specified by:

removeRoutingConnection in class Scheduler

getNumberConnections

public int getNumberConnections()

Specified by:

getNumberConnections in class Scheduler

close

public void close()

Specified by:

close in class Scheduler

toString

public String toString()

Overrides:

toString in class Scheduler