查看weblogic的帮助文档,说是很难说的清楚的!
解决方案 »
- 数据库中出现奇怪的事
- Struts2+Spring访问文件时出现问题
- 找一些经典的java学习书籍,电子书也可以
- JSF 报错:Error while processing state !
- js日历控件 弹出位置偏上的问题
- Java正则表达式
- 大家给我讲讲javabean,ejb,jsp,servlet ,jdbc的基本概念和大家在项目中是如何运用他们的?
- 如何改变Tomcat的欢迎页面啊?
- 如何配置WebLogic7.0的jdbc connection pools??
- 关于JDBC连接ORACLE9I的问题~~~~~~~~~~~
- 各位高手,我对java的基本概念已经理解的差不多了,现在我想转到EJB上来,但我需要从那下手?
- 哪位能给我指点一下CLASSPATH的设置方法(在线等待==在线结贴)
然后选择jmsserver下的Destinations结点,并点击右键选择config a new jmsqueue. 输入name和jndiname的名字(name和jndiname相同)。
在程序中使用lookup即可查询jms的jndi名。简单的代码:
public class SSMessage
{ public static final int leJMSException = 0;
public static final char mtQueue = 81;
QueueSession queueSession;
Queue queue;
QueueSender queueSender; /**
* 创建消息队列的生产者
* @param c 无意义
* @param s 无意义
* @throws SSException
* @throws SQLException
* @throws NamingException
*/
public SSMessage(char c, String s)
throws SSException, SQLException, NamingException
{
queueSession = null;
queue = null;
queueSender = null;
try
{
//得到jms的连接工厂
QueueConnectionFactory queueconnectionfactory = (QueueConnectionFactory)SSResource.lookup(0);
//创建jms的连接
QueueConnection queueconnection = queueconnectionfactory.createQueueConnection();
//创建jms的会话
queueSession = queueconnection.createQueueSession(false, 1);
//queue = (Queue)SSResource.lookup("IlmsBatchQueue");
//查找jms的jndi名
queue = (Queue)SSResource.lookup(SSResource.qnBatch);
//根据特定的会话创建消息的生产者
queueSender = queueSession.createSender(queue);
}
catch(JMSException jmsexception)
{
//throw new SSLogiException(0, "出现JMSException", toString(), "SSMessage()", jmsexception);
throw new SSLogiException(leJMSException, "出现JMSException", toString(), "send()", jmsexception);
}
} /**
* 传递消息
* @param serializable
* @throws SSException
* @throws SQLException
* @throws NamingException
*/
public void send(Serializable serializable)
throws SSException, SQLException, NamingException
{
try
{
javax.jms.ObjectMessage objectmessage = queueSession.createObjectMessage(serializable);
//传送消息到消息队列中
queueSender.send(objectmessage);
}
catch(JMSException jmsexception)
{
//throw new SSLogiException(0, "出现JMSException", toString(), "send()", jmsexception);
throw new SSLogiException(leJMSException, "出现JMSException", toString(), "send()", jmsexception);
}
}
}