wayne

2008年9月14日 #

JMS (2)

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

 1@Stateless
 2public 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，实际上这一步是不可缺少的。

posted @ 2008-09-14 16:40 waynemao 阅读(110) | 评论 (0) | 编辑 收藏

JMS (1)

     摘要: 开发任何JMS应用之前，首先要做的事是在应用服务器中配置JMS被管对象：连接工厂和目的地。它们最好不要以编程的方式实现，因为其背后的技术有多种不同的API实现，可能无法移植。以下是glassfish中的配置： 在配置--java消息服务里创建两个物理目的地  名称：myQueue  类型：javax.jms.Queue  名称：myTopic  类...  阅读全文

posted @ 2008-09-14 05:31 waynemao 阅读(309) | 评论 (0) | 编辑 收藏

My Links

Blog Stats

常用链接

留言簿(1)

随笔分类

随笔档案

default

搜索

最新评论

阅读排行榜

评论排行榜