浏览 6756 次
锁定老帖子 主题:JMS发送消息实例
精华帖 (0) :: 良好帖 (0) :: 隐藏帖 (0)
|
|
---|---|
作者 | 正文 |
发表时间:2008-05-05
最后修改:2009-07-08
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("发送成功"); } } 声明:ITeye文章版权属于作者,受法律保护。没有作者书面许可不得转载。
推荐链接
|
|
返回顶楼 | |
发表时间:2008-05-05
我在上海,也没几个电话,看来简历不夸张点是不行了
|
|
返回顶楼 | |
发表时间:2008-05-05
happynoob 写道 我在上海,也没几个电话,看来简历不夸张点是不行了
把简历夸张了,那么在面试的时候,hr问的问题就加深了 |
|
返回顶楼 | |
发表时间:2008-05-05
我们招人单位也遇到了这个问题,职位空缺了3个月了,就2个人投了简历。信息严重不对称。
|
|
返回顶楼 | |
发表时间:2008-05-05
webug 写道 我们招人单位也遇到了这个问题,职位空缺了3个月了,就2个人投了简历。信息严重不对称。
请问你公司现在招人吗?我可以试试 |
|
返回顶楼 | |
发表时间:2008-05-05
怎么搞的,我还一度怀疑上海的java工程师紧缺了呢,招人招到现在还有三个职位空缺。
|
|
返回顶楼 | |
发表时间:2008-05-06
zhouyaoh 写道 怎么搞的,我还一度怀疑上海的java工程师紧缺了呢,招人招到现在还有三个职位空缺。
找的找工作不到 招的招不到人 很矛盾 |
|
返回顶楼 | |
发表时间:2008-05-06
6246850 写道 zhouyaoh 写道 怎么搞的,我还一度怀疑上海的java工程师紧缺了呢,招人招到现在还有三个职位空缺。
找的找工作不到 招的招不到人 很矛盾 事实上,这并不矛盾. 这正如有很多人买不起汽车,也有很多汽车生产出来卖不出去一样. |
|
返回顶楼 | |
发表时间:2008-05-06
xellos 写道 6246850 写道 zhouyaoh 写道 怎么搞的,我还一度怀疑上海的java工程师紧缺了呢,招人招到现在还有三个职位空缺。
找的找工作不到 招的招不到人 很矛盾 事实上,这并不矛盾. 这正如有很多人买不起汽车,也有很多汽车生产出来卖不出去一样. 你不觉得买汽车和找工作是不一样的吗? 没有汽车,你可以脚走路!而且你不用重新学这路 没有工作你却难以生活,换工作?那就得一切重新来 |
|
返回顶楼 | |