1 package ch02.chat;
 2
 3 import javax.jms.JMSException;
 4
 5 public class ClientTest3 {
 6
 7     public static void main(String[] args) throws JMSException {
 8         // TODO Auto-generated method stub
 9         JMSTopic jt=new JMSTopic();
10         jt.setSession();
11         //发送5个消息到queue2
12         for(int i=0;i<10;i++)
13         {
14             jt.writeMessage("queue2", "xo"+i,4);
15
16         }
17
18
19     }
20
21 }

 1 package ch02.chat;
 2
 3 import javax.jms.JMSException;
 4 import javax.jms.Message;
 5 import javax.jms.MessageListener;
 6 import javax.jms.TextMessage;
 7
 8 public class ClientTest3Response {
 9
10
11     public static void main(String[] args) throws JMSException {
12         // TODO Auto-generated method stub
13         JMSTopic jt=new JMSTopic();
14         jt.setSession();
15
16         //异步接收信息,监听queue2
17
18         System.out.println("异步接收前");
19
20
21
22         jt.receiveMsg("queue2", new  MessageListener() {
23
24             @Override
25             //当topic， queue2中有信息的时候
26             public void onMessage(Message message) {
27
28                 TextMessage mm=(TextMessage)message;
29                 try {
30                     System.out.println("接收到信息"+mm.getText());
31                 } catch (JMSException e) {
32                     // TODO Auto-generated catch block
33                     e.printStackTrace();
34                 }
35
36             }
37         });
38
39         System.out.println("异步接收后");
40
41         }
42     }