开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Java编程 > 查看源码
MessageSender.java
资源名称：某公司的java培训教材　[点击查看]
上传用户：dinglihq
上传日期：2013-02-04
资源大小：99958k
文件大小：1k
源码类别：

Java编程

开发平台：

Java

MessageSender.java：源码内容
  1. package day21ex.messagesender;
  2. import java.io.*;
  3. import java.util.*;
  4. import javax.transaction.*;
  5. import javax.naming.*;
  6. import javax.jms.*;
  7. import javax.ejb.*;
  9. public class MessageSender{
  10.    public final static String JMS_FACTORY =
  11.                     "java:comp/env/jms/TopicConnectionFactory";
  12.    public final static String TOPIC =
  13.                     "java:comp/env/jms/OrderVerifierTopic";
  14.    public void sendAMessage(Context jndiCtx, String msg)  {
  15.       TopicConnection tConnect = null;
  16.       try {
  17.          TopicConnectionFactory tFactory = 
  18.             (TopicConnectionFactory) jndiCtx.lookup(JMS_FACTORY);
  19.          Topic t = (Topic)jndiCtx.lookup(TOPIC);
  20.          tConnect = 
  21.             tFactory.createTopicConnection();
  22.          TopicSession session = tConnect.createTopicSession(false,
  23.                                QueueSession.AUTO_ACKNOWLEDGE);
  24.          TopicPublisher publisher = session.createPublisher(t);
  25.          TextMessage jmsMsg = session.createTextMessage();
  26.          jmsMsg.setText(msg);
  27.          publisher.publish(jmsMsg);
  28.          print("Message sent to the topic:" + msg);
  29.       }catch  (Exception e) {
  30.          e.printStackTrace();
  31.          throw new EJBException("MessageSender:sendAMessage: Error!",e);
  32.       } finally {
  33.          try {
  34.             if( tConnect != null ) {
  35.                tConnect.close();
  36.             }
  37.          } catch(Exception e) {}
  38.       }
  39.    }
  40.    void print(String s) {
  41.       System.out.println("MessageSender:"+ s);
  42.    }
  44. }