Package com.webmethods.jms.loadbalance.policy

Class WmClusterMultiSendXA

java.lang.Object

com.webmethods.jms.loadbalance.policy.WmClusterPolicy

com.webmethods.jms.loadbalance.policy.WmClusterMultiSendXA

public class WmClusterMultiSendXA
extends WmClusterPolicy

Field Summary

Fields inherited from class com.webmethods.jms.loadbalance.policy.WmClusterPolicy

random

Constructor Summary

Constructors

Constructor	Description
WmClusterMultiSendXA()

Method Summary

Modifier and Type	Method	Description
static java.util.List<java.util.List<java.lang.String>>	getGroups(java.lang.String[] brokers, int n, int k, java.util.List<java.util.List<java.lang.String>> groupsFromSmallerSet)
int	getNextPublishBroker(WmClusterConnectionImpl clusterConn)	Find the next Broker to publish to in the list according to the policy rules.
int	getNextPublishCluster(WmCompositeClusterConnectionImpl clusterConn)
static java.util.List<java.lang.String[]>	getSubsets(java.lang.String[] brokers, int n, int k, java.util.List<java.lang.String[]> entries)

Methods inherited from class com.webmethods.jms.loadbalance.policy.WmClusterPolicy

getAllBrokers, getAllBrokerURLs, getName

Methods inherited from class java.lang.Object

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

Constructor Detail

WmClusterMultiSendXA

public WmClusterMultiSendXA()

Method Detail

getNextPublishBroker

public int getNextPublishBroker(WmClusterConnectionImpl clusterConn)

Find the next Broker to publish to in the list according to the policy rules. Order may not be relevant to some policies.

Specified by:

getNextPublishBroker in class WmClusterPolicy

getNextPublishCluster

public int getNextPublishCluster(WmCompositeClusterConnectionImpl clusterConn)

Specified by:

getNextPublishCluster in class WmClusterPolicy

getSubsets

public static java.util.List<java.lang.String[]> getSubsets(java.lang.String[] brokers,
                                                            int n,
                                                            int k,
                                                            java.util.List<java.lang.String[]> entries)

getGroups

public static java.util.List<java.util.List<java.lang.String>> getGroups(java.lang.String[] brokers,
                                                                         int n,
                                                                         int k,
                                                                         java.util.List<java.util.List<java.lang.String>> groupsFromSmallerSet)