神呀！救救我吧！sun MessageQueue 群集问题

Question

发送消息
public class TestCreateQueue { /**
 * @param args
 * @throws JMSException 
 * @throws NamingException 
 */
public static void main(String[] args) throws NamingException, JMSException {
// TODO Auto-generated method stub
ConnectionFactory1 tcf = new ConnectionFactory1();
ConnectionFactory myQConnFactory = tcf.findFactory();
QueueConnection myQConn = myQConnFactory.createQueueConnection();
QueueSession qSession = myQConn.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
Queue myQueue = new Queue();

try {
myQueue.setProperty("imqDestinationName","q1");
QueueSender qs = qSession.createSender((javax.jms.Queue)myQueue);
} catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

MessageProducer sender = qSession.createSender(myQueue);
TextMessage tMessage = qSession.createTextMessage();
tMessage.setText("11111111111111111111");
sender.send(tMessage);
qSession.close();
myQConn.close();

}}

Answer 1

查看消息
public static void main(String[] args) throws NamingException, JMSException{
// TODO Auto-generated method stub

//for(int i=0;i<5;i++){
ConnectionFactory1 tcf = new ConnectionFactory1();
ConnectionFactory myQConnFactory = tcf.findFactory();
QueueConnection myQConn = myQConnFactory.createQueueConnection();
Session session = null;
QueueBrowser browser = null;
Queue myQueue = new Queue();
myQueue.setProperty("imqDestinationName","q1");
session = myQConn.createSession(false, Session.AUTO_ACKNOWLEDGE);
browser = session.createBrowser(myQueue);
myQConn.start();
Enumeration messages = browser.getEnumeration();
//System.out.println(messages);
while (messages.hasMoreElements()) {
Message message = (Message) messages.nextElement();
System.out.println(message);
}

session.close();
myQConn.close();

//}
}}

Answer 2

连接工厂的代码（重发）：
public class ConnectionFactory1 {

/**
 * 测试连接  链接工厂
 * */
public ConnectionFactory findFactory() throws NamingException, JMSException {
ConnectionFactory myQConnFactory = new ConnectionFactory();
myQConnFactory.setProperty(ConnectionConfiguration.imqAddressList,"192.168.0.100:7676,192.168.0.2:7676");
myQConnFactory.setProperty(ConnectionConfiguration.imqAddressListBehavior,"RANDOM");
return myQConnFactory;
}
}