WmQueueConnectionFactoryImpl queueCF = null;

queueCF = (WmQueueConnectionFactoryImpl)
WmJMSFactory.getQueueConnectionFactory();

// set the JMS Client group
queueCF.setClientGroup(clientGroup);

// set the brokers in the cluster
factory.setBrokerCluster( new String[] {"Broker1@localhost:6849",
"Broker2@localhost:6949",
"Broker3@localhost:7010"} );

// set the load balancing policy as Multi Send Best effort
queueCF.setClusterPolicy(WmClusterPolicyManager.MULTISEND_BEST_EFFORT);

// set the maximum number of brokers count
queueCF.setMultiSendCount(2);

QueueConnection queueConnection = (QueueConnection)
queueCF.createQueueConnection();
queueConnection.start();

QueueSession queueSession = queueConnection.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);

MessageProducer producer = queueSession.createProducer(queue);

TextMessage message = null;

for (int i = 0; i < 10; ++i)
{
message = queueSession.createTextMessage();
message.setText("QueueMessage " + i);
producer.send(message);
}

producer.close();
queueSession.close();
queueConnection.close();