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

Class MessageGroupDispatchPolicy

java.lang.Object

com.swiftmq.impl.queue.standard.cluster.MessageGroupDispatchPolicy

All Implemented Interfaces:

DispatchPolicy, DispatchPolicyListener

public class MessageGroupDispatchPolicy
extends Object
implements DispatchPolicy, DispatchPolicyListener

Constructor Summary

Constructors

Constructor	Description
MessageGroupDispatchPolicy(SwiftletContext ctx, Entity myEntity, String clusteredQueueName, DispatchPolicy parent)

Method Summary

Modifier and Type	Method	Description
void	addLocalMetric(QueueMetric metric)
void	addMetric(String routerName, ClusteredQueueMetric metric)
void	close()
protected MessageGroupEntry	createNewGroupEntry(Object value)
protected void	deleteGroupEntry(MessageGroupEntry entry)
void	dispatchQueueRemoved(String queueName)
String	getClusteredQueueName()
Map	getGroups()
ClusteredQueueMetric	getLocalMetric()
String	getNextReceiveQueue()
String	getNextSendQueue()
String	getNextSendQueue(MessageImpl message)
boolean	isMessageBasedDispatch()
boolean	isReceiverSomewhere()
void	performTimeAction()
void	receiverCountChanged(AbstractQueue abstractQueue, int receiverCount)
void	removeLocalMetric(QueueMetric metric)
void	removeMetric(String routerName)
protected void	reset()
void	setDispatchPolicyListener(DispatchPolicyListener l)
void	setGroups(Map groups)
String	toString()
protected void	updateGroupEntry(MessageGroupEntry entry)

Methods inherited from class java.lang.Object

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

Constructor Details

MessageGroupDispatchPolicy

public MessageGroupDispatchPolicy(SwiftletContext ctx,
 Entity myEntity,
 String clusteredQueueName,
 DispatchPolicy parent)

Method Details

reset

protected void reset()

getClusteredQueueName

public String getClusteredQueueName()

setGroups

public void setGroups(Map groups)

getGroups

public Map getGroups()

performTimeAction

public void performTimeAction()

setDispatchPolicyListener

public void setDispatchPolicyListener(DispatchPolicyListener l)

Specified by:

setDispatchPolicyListener in interface DispatchPolicy

dispatchQueueRemoved

public void dispatchQueueRemoved(String queueName)

Specified by:

dispatchQueueRemoved in interface DispatchPolicyListener

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

createNewGroupEntry

protected MessageGroupEntry createNewGroupEntry(Object value)

updateGroupEntry

protected void updateGroupEntry(MessageGroupEntry entry)

deleteGroupEntry

protected void deleteGroupEntry(MessageGroupEntry entry)

getNextSendQueue

public String getNextSendQueue(MessageImpl message)

Specified by:

getNextSendQueue in interface DispatchPolicy

getNextReceiveQueue

public String getNextReceiveQueue()

Specified by:

getNextReceiveQueue in interface DispatchPolicy

receiverCountChanged

public void receiverCountChanged(AbstractQueue abstractQueue,
 int receiverCount)

close

public void close()

Specified by:

close in interface DispatchPolicy

toString

public String toString()

Overrides:

toString in class Object