Package com.swiftmq.impl.queue.standard.cluster

Class RoundRobinDispatchPolicy

java.lang.Object

com.swiftmq.impl.queue.standard.cluster.RoundRobinDispatchPolicy

All Implemented Interfaces:

DispatchPolicy

public class RoundRobinDispatchPolicy
extends Object
implements DispatchPolicy

Constructor Summary

Constructors

Constructor	Description
RoundRobinDispatchPolicy(SwiftletContext ctx, String clusteredQueueName)

Method Summary

Modifier and Type	Method	Description
void	addLocalMetric(QueueMetric metric)
void	addMetric(String routerName, ClusteredQueueMetric metric)
void	close()
ClusteredQueueMetric	getLocalMetric()
String	getNextReceiveQueue()
String	getNextSendQueue()
String	getNextSendQueue(MessageImpl message)
boolean	isMessageBasedDispatch()
boolean	isReceiverSomewhere()
void	receiverCountChanged(AbstractQueue abstractQueue, int receiverCount)
void	removeLocalMetric(QueueMetric metric)
void	removeMetric(String routerName)
void	setDispatchPolicyListener(DispatchPolicyListener listener)

Methods inherited from class java.lang.Object

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

Constructor Details

RoundRobinDispatchPolicy

public RoundRobinDispatchPolicy(SwiftletContext ctx,
 String clusteredQueueName)

Method Details

setDispatchPolicyListener

public void setDispatchPolicyListener(DispatchPolicyListener listener)

Specified by:

setDispatchPolicyListener in interface DispatchPolicy

receiverCountChanged

public void receiverCountChanged(AbstractQueue abstractQueue,
 int receiverCount)

addLocalMetric

public void addLocalMetric(QueueMetric metric)

Specified by:

addLocalMetric in interface DispatchPolicy

removeLocalMetric

public void removeLocalMetric(QueueMetric metric)

Specified by:

removeLocalMetric in interface DispatchPolicy

getLocalMetric

public ClusteredQueueMetric getLocalMetric()

Specified by:

getLocalMetric in interface DispatchPolicy

addMetric

public void addMetric(String routerName,
 ClusteredQueueMetric metric)

Specified by:

addMetric in interface DispatchPolicy

removeMetric

public void removeMetric(String routerName)

Specified by:

removeMetric in interface DispatchPolicy

isReceiverSomewhere

public boolean isReceiverSomewhere()

Specified by:

isReceiverSomewhere in interface DispatchPolicy

isMessageBasedDispatch

public boolean isMessageBasedDispatch()

Specified by:

isMessageBasedDispatch in interface DispatchPolicy

getNextSendQueue

public String getNextSendQueue()

Specified by:

getNextSendQueue in interface DispatchPolicy

getNextSendQueue

public String getNextSendQueue(MessageImpl message)

Specified by:

getNextSendQueue in interface DispatchPolicy

getNextReceiveQueue

public String getNextReceiveQueue()

Specified by:

getNextReceiveQueue in interface DispatchPolicy

close

public void close()

Specified by:

close in interface DispatchPolicy