Class Scheduler

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

DefaultScheduler

public abstract class Scheduler
extends Object
implements POSchedulerVisitor, DeliveryCallback

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
abstract void	addRoute(Route route)
abstract void	close()
protected void	connectionAdded(RoutingConnection connection)
protected void	connectionRemoved(RoutingConnection connection)
void	delivered(DeliveryRequest deliveryRequest)
protected void	enqueueClose(POCloseObject po)
protected abstract RoutingConnection	getNextConnection()
abstract int	getNumberConnections()
String	getQueueName()
abstract void	removeRoute(Route route)
abstract void	removeRoutingConnection(RoutingConnection routingConnection)
String	toString()
void	visit(POCloseObject po)
void	visit(POConnectionAddedObject po)
void	visit(POConnectionRemovedObject po)
void	visit(PODeliveredObject po)
void	visit(PODeliverObject po)

Methods inherited from class Object

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

Constructor Details

Scheduler

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

Method Details

getQueueName

public String getQueueName()

addRoute

public abstract void addRoute(Route route)

removeRoute

public abstract void removeRoute(Route route)

removeRoutingConnection

public abstract void removeRoutingConnection(RoutingConnection routingConnection)

getNumberConnections

public abstract int getNumberConnections()

getNextConnection

protected abstract RoutingConnection getNextConnection()

close

public abstract void close()

delivered

public void delivered(DeliveryRequest deliveryRequest)

Specified by:

delivered in interface DeliveryCallback

connectionAdded

protected void connectionAdded(RoutingConnection connection)

connectionRemoved

protected void connectionRemoved(RoutingConnection connection)

enqueueClose

protected void enqueueClose(POCloseObject po)

visit

public void visit(PODeliverObject po)

Specified by:

visit in interface POSchedulerVisitor

visit

public void visit(PODeliveredObject po)

Specified by:

visit in interface POSchedulerVisitor

visit

public void visit(POConnectionAddedObject po)

Specified by:

visit in interface POSchedulerVisitor

visit

public void visit(POConnectionRemovedObject po)

Specified by:

visit in interface POSchedulerVisitor

visit

public void visit(POCloseObject po)

Specified by:

visit in interface POSchedulerVisitor

toString

public String toString()

Overrides:

toString in class Object