// create the connection factory
WmConnectionFactory factory = new WmConnectionFactoryImpl();
factory.setClientGroup(clientGroup);
factory.setBrokerCluster( new String[] {"Broker #1@localhost:6849",
"Broker2@localhost:6949",
"Broker3@localhost:7010"} );

// set the load balancing policy as Weighted Round Robin
factory.setClusterPolicy(WmClusterPolicyManager.WEIGHTED_ROUND_ROBIN);

// Set the weight for each Broker in the cluster
CopyOnWriteArrayList<WeightedRoundRobin> weightList = new
CopyOnWriteArrayList<WeightedRoundRobin>();

WeightedRoundRobin wrr1 = new WeightedRoundRobin();
wrr1.setBrokerName("Broker #1@localhost:6849");
wrr1.setWeight(Integer.parseInt("1"));

WeightedRoundRobin wrr2 = new WeightedRoundRobin();
wrr2.setBrokerName("Broker2@localhost:6949");
wrr2.setWeight(Integer.parseInt("2"));

WeightedRoundRobin wrr3 = new WeightedRoundRobin();
wrr3.setBrokerName("Broker3@localhost:7010");
wrr3.setWeight(Integer.parseInt("2"));

weightList.add(wrr1);
weightList.add(wrr2);
weightList.add(wrr3);

// Set the weights for the factory
factory.setWeightedRoundRobinList(weightList);

// Create the JMS Connection
connection = (Connection) factory.createConnection();
connection.start();

// Create the JMS session
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(queue);

// publish JMS Messages
for ( int i =0; i< 10000; i++) {
producer.send(session.createTextMessage());
}

// For the above weights set on the Brokers,
// BrokerA should get 2000 documents
// BrokerB should get 4000 documents
// BrokerC should get 4000 documents