JMS(2)

异步队列消息的接收有一点区别，但发送的代码不用改变：

 1 @Stateless 

 2 public class JMSReceiveBean implements JMSReceiveRemote {
 3
 4    @Resource(name = "jms/Queue")
 5    private Queue queue;
 6    @Resource(name = "jms/ConnectionFactory")
 7    private ConnectionFactory queueFactory;
 8
 9    private void receiveJMSMessageFromQueue() throws Exception {
10        Connection connection = null;
11        Session session = null;
12        connection = queueFactory.createConnection();
13        session = connection.createSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);
14        MessageConsumer consumer = session.createConsumer(queue);
15        consumer.setMessageListener(new MessageListener() {
16
17            public void onMessage(Message message) {
18                TextMessage msg = (TextMessage) message;
19                try {
20                    String txt = msg.getText();
21                    Logger.getLogger(JMSReceiveBean.class.getName()).log(Level.SEVERE, txt);
22                } catch (Exception ex) {
23                    ex.printStackTrace();
24                }
25            }
26        });
27        
28        connection.start();
29    }
30
31    public void receiveMessage() {
32        try 
33            receiveJMSMessageFromQueue();
34        } catch (Exception ex) {
35            Logger.getLogger(JMSReceiveBean.class.getName()).log(Level.SEVERE, null, ex);
36        }
37    }
38}

在15行消息使用者上设置了一个消息监听器，而没有使用同步的receive方法。由于这是异步接收消息，程序并没有处于阻塞状态，为了避免在接收到消息之前连接终止，所以在28行之后并没有关闭Connection，实际上这一步是不可缺少的。