package com.sourceware.sms.platform.jms;
import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import com.sourceware.sms.SMS;
import org.apache.log4j.Logger;
/**
* <p>标题: 短信平台</p>
* <p>描述: 短信平台以及相关业务。</p>
* <p>版权: 宁波友科软件有限公司 Copyright (c) 2004</p>
* <p>公司: 宁波友科软件有限公司</p>
* @author 吴锋彬(woowind@sina.com)
* @version 1.0
*/
public class JMSQueueSend {
Logger logger = Logger.getLogger(JMSQueueSend.class);
public JMSQueueSend() {
}
public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";
private static String JMS_FACTORY = "JNDI_JMS_Connection_Factory";
private static String QUEUE = null;
private QueueConnectionFactory qconFactory;
private QueueConnection qcon;
private weblogic.jms.extensions.WLQueueSession qsession;
private weblogic.jms.client.JMSProducer qsender;
private Queue queue;
private ObjectMessage msg;
/**
* Creates all the necessary objects for sending
* messages to a JMS queue.
*
* @param ctx JNDI initial context
* @param queueName name of queue
* @exception NamingException if operation cannot be performed
* @exception JMSException if JMS fails to initialize due to internal error
*/
void init(Context ctx, String queueName) throws NamingException, JMSException {
qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY);
qcon = qconFactory.createQueueConnection();
qsession = (weblogic.jms.extensions.WLQueueSession) qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
queue = (Queue) ctx.lookup(queueName);
qsender = (weblogic.jms.client.JMSProducer) qsession.createSender(queue);
msg = qsession.createObjectMessage();
logger.debug(qconFactory + "["
+ qcon.getClass().getName()
+ "]"
+ "["
+ qsession.getClass().getName()
+ "]"
+ "["
+ qsender.getClass().getName()
+ "]"
+ "["
+ msg.getClass().getName()
+ "]");
qcon.start();
}
/**
* Closes JMS objects.
* @exception JMSException if JMS fails to close objects due to internal error
*/
void close() throws JMSException {
qsender.close();
qsession.close();
qcon.close();
}
/**
*
* @param SMS SMS
* @throws Exception
*/
public void sendMO(SMS sms) throws Exception {
InitialContext ic = new InitialContext();
init(ic, "JNDI_CMW_SMS_MO_QUEUE");
msg.setJMSExpiration(sms.getExpiration());
msg.setJMSMessageID(new Long(sms.getMessageID()).toString());
long time2Deliver = sms.getSheduleTime().getTime() - System.currentTimeMillis();
if (time2Deliver > 0) {
qsender.setTimeToDeliver(time2Deliver);//定时
}
msg.setObject(sms);
msg.setJMSPriority(sms.getPriority());
qsender.send(msg);
this.close();
}
/**
*
* @param SMS SMS
* @throws Exception
*/
public void sendMT(SMS sms) throws Exception {
InitialContext ic = new InitialContext();
init(ic, "JNDI_CMW_SMS_MT_QUEUE");
msg.setJMSExpiration(sms.getExpiration());
msg.setJMSMessageID(new Long(sms.getMessageID()).toString());
long time2Deliver = sms.getSheduleTime().getTime() - System.currentTimeMillis();
if (time2Deliver > 0) {
qsender.setTimeToDeliver(time2Deliver);
}
msg.setObject(sms);
msg.setJMSPriority(sms.getPriority());
qsender.send(msg);
this.close();
}
/**
*
* @param sms SMS
* @param jndiName String
* @throws Exception
*/
public void send(SMS sms, String jndiName) throws Exception {
InitialContext ic = new InitialContext();
init(ic, jndiName);
msg.setJMSExpiration(sms.getExpiration());
msg.setJMSMessageID(new Long(sms.getMessageID()).toString());
long time2Deliver = sms.getSheduleTime().getTime() - System.currentTimeMillis();
if (time2Deliver > 0) {
qsender.setTimeToDeliver(time2Deliver);
}
msg.setObject(sms);
msg.setJMSPriority(sms.getPriority());
qsender.send(msg);
this.close();
}
}
分享到:
相关推荐
weblogic中使用JMS发送和接受消息(Queue and TOPIC)
这是本人搭建的Spring框架,集成了Weblogic JMS,测试已经完成。现提供给大家下载学习。
自己写好的一个简单的weblogic jms的简单实现,包括点对点的实现,以及topic的实现,适合初学者参考
描述了weblogic jms服务器的配置
实现了jms的queue和topic,同时也实现了远程传送消息和本地传送消息,另外也分别实现了session的事务和非事务模式,有了这三个例子应该可以满足你的任何关于jms的需求了,由于上传限制,另外还需要下载有个WebLogic包...
webLogic9.2配置JMS步骤,发布/订阅消息发送方式
本人开发的spring jms项目,已经上线近一年了,这里是我项目jms配置文件,使用的是spring jms 整合weblogic jms。如果真的需要,请咨询我,并且附上我上传的这个配置文件,附近中没有带有这个文件,一律不作任何回答...
描述在Weblogic环境下如何进行JMS 消息队列的开发。
JMS 简介以及Weblogic配置JMS图解
WebLogic_JMS的概念,分类,实现形式,甚至有具体的编码
Linux下WebLogic集群的部署以及jms部署完整版
NULL 博文链接:https://ldxyll.iteye.com/blog/914319
NULL 博文链接:https://jackaney.iteye.com/blog/1276918
通过详细的步骤说明(有截图和文字说明),从Weblogic安装到Weblogic集群搭建最后配置Weblogic JMS集群。看不懂的话可以相互交流谢谢。
Weblogic_JMS+配置数据源配置
详解weblogic上部署JMS,配有每一步的图片。
对Weblogic进行定时重新启动的总结
本例详细介绍了如何配置JMS服务以及weblogic的安装及在weblogic中配置JMS服务,例子简单易懂,文档含代码,适合初学者学习使用
使用Weblogic 11g创建JMS消息服务,创建生产者和消费者对消息队列进行操作,需要的jar包,提供给大家下载
文件内有springboot 集成jms源码 ,自己写的小demo测试过没有问题。。