JMS发送消息实例

package com.eway.jms;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

import javax.jms.JMSException;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import com.eway.pojo.Inhospitaldata;
import com.eway.util.Propertie;

/**
*
* @author yanghui
* @2009-07-03
* @消息发送
*
*/
public class QMProducer {
/**
* 定义JNDI上下文构造器
*/
public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";
/**
* 定义JMS上下文构造器
*/
public final static String JMS_FACTORY = "jms/QueueConnectionFactory";
/***************************************************************************
* 定义消息列队
*/
public final static String QUEUE = "jms/fileQueue";
// 声明队列连接构造器
private QueueConnectionFactory queueConnectionFactory = null;
// 声明队列连接
private QueueConnection queueConnection = null;
// 声明队列会话
private QueueSession queueSession = null;
// 声明队列发送
private QueueSender queueSender = null;
// 声明队列
private Queue queue = null;
// 声明发送对象方式
private ObjectMessage msg = null;

public void init(Context ctx, String queueName) {
   try {
    queueConnectionFactory = (QueueConnectionFactory) ctx
      .lookup(JMS_FACTORY);
    queueConnection = queueConnectionFactory.createQueueConnection();
    queueSession = queueConnection.createQueueSession(false,
      Session.AUTO_ACKNOWLEDGE);
    queue = (Queue) ctx.lookup(queueName);
    queueSender = queueSession.createSender(queue);
    msg = queueSession.createObjectMessage();
    queueConnection.start();
   } catch (NamingException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   } catch (JMSException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
}

public void send(List<Inhospitaldata> message) throws JMSException {

   msg.setObject((Serializable) message);
   queueSender.send(msg);

}

public void close() throws JMSException {
   queueSender.close();
   queueSession.close();
   queueConnection.close();
}

public void sendInfo(List<Inhospitaldata> inhospitaldataList) {
   try {

    System.setProperty(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
    System.setProperty(Context.PROVIDER_URL, Propertie.getPropertie()
      .getProperty("provider"));
    Context context = new InitialContext();
    init(context, QUEUE);
    send(inhospitaldataList);

   } catch (NamingException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   } catch (JMSException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   } finally {
    try {
     close();
    } catch (JMSException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
   }
}

public static void main(String[] args) {
   QMProducer producer = new QMProducer();
   Inhospitaldata inhospitaldata = new Inhospitaldata();
   inhospitaldata.setXm("yanghui131");
   List<Inhospitaldata> list = new ArrayList<Inhospitaldata>();
   list.add(inhospitaldata);
   producer.sendInfo(list);
   System.out.println("发送成功");
}
}

评论

8 楼 6246850 2008-05-06  

xellos 写道

6246850 写道

zhouyaoh 写道

怎么搞的，我还一度怀疑上海的java工程师紧缺了呢，招人招到现在还有三个职位空缺。

找的找工作不到
招的招不到人
很矛盾

事实上,这并不矛盾.
这正如有很多人买不起汽车,也有很多汽车生产出来卖不出去一样.

你不觉得买汽车和找工作是不一样的吗?
没有汽车,你可以脚走路!而且你不用重新学这路
没有工作你却难以生活,换工作?那就得一切重新来

7 楼 xellos 2008-05-06  

6246850 写道

zhouyaoh 写道

怎么搞的，我还一度怀疑上海的java工程师紧缺了呢，招人招到现在还有三个职位空缺。

找的找工作不到
招的招不到人
很矛盾

事实上,这并不矛盾.
这正如有很多人买不起汽车,也有很多汽车生产出来卖不出去一样.

6 楼 6246850 2008-05-06  

zhouyaoh 写道

怎么搞的，我还一度怀疑上海的java工程师紧缺了呢，招人招到现在还有三个职位空缺。

找的找工作不到
招的招不到人
很矛盾

5 楼 zhouyaoh 2008-05-05  

怎么搞的，我还一度怀疑上海的java工程师紧缺了呢，招人招到现在还有三个职位空缺。

4 楼 6246850 2008-05-05  

webug 写道

我们招人单位也遇到了这个问题，职位空缺了3个月了，就2个人投了简历。信息严重不对称。

请问你公司现在招人吗?我可以试试

3 楼 webug 2008-05-05  

我们招人单位也遇到了这个问题，职位空缺了3个月了，就2个人投了简历。信息严重不对称。

2 楼 6246850 2008-05-05  

happynoob 写道

我在上海，也没几个电话，看来简历不夸张点是不行了

把简历夸张了,那么在面试的时候,hr问的问题就加深了

1 楼 happynoob 2008-05-05  

我在上海，也没几个电话，看来简历不夸张点是不行了