eclipse + JBoss 5 + EJB3开发指南（14）：消息驱动Bean - 编程入门网
作者 佚名技术
来源 NET编程
浏览
发布时间 2012-06-15
public class GreeterBean implements Greeter
{
@Resource(mappedName = "ConnectionFactory")
private ConnectionFactory cf;
@Resource(mappedName = "queue/MDBQueue")
private Queue queue;
@Override
public String greet(String message)
{
try
{
DateBean db = new DateBean();
db.setMyDate(new Date());
Connection connection = cf.createConnection();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
MessageProducer messageProducer = session.createProducer(queue);
ObjectMessage objectMessage = session.createObjectMessage();
objectMessage.setObject(db);
messageProducer.send(objectMessage);
connection.close();
System.out.println("成功发送消息！");
}
catch (Exception e)
{
System.out.println("发送消息失败！");
}
return "方法成功返回";
}
}
eclipse + JBoss 5 + EJB3开发指南（14）：消息驱动Bean(4)时间:2011-09-18 blogjava 哈佛校训在上面的代码中使用ObjectMessage对象来包装要向消息服务器发送的实体Bean的对象实例。 除了可以在SessionBean中访问消息驱动Bean外，还可以在不同的机器上通过jndi来查找并调用消息驱 动Bean，代码如下:
package test;
import java.util.Date;
import javax.ejb.EJB;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import entity.DateBean;
import service.Greeter;
public class Client
{
public static void main(String[] args) throws Exception
{
InitialContext ctx = new InitialContext();
QueueConnection connection = null;
QueueSession session = null;
QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup
("ConnectionFactory");
connection = factory.createQueueConnection();
session = connection.createQueueSession(false,
QueueSession.AUTO_ACKNOWLEDGE);
Destination destination = (Queue) ctx.lookup("queue/MDBQueue");
MessageProducer messageProducer = session.createProducer(destination);
ObjectMessage objectMessage = session.createObjectMessage();
DateBean db = new DateBean();
db.setMyDate(new Date());
objectMessage.setObject(db);
messageProducer.send(objectMess |
凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢! |
你可能对下面的文章感兴趣
关于eclipse + JBoss 5 + EJB3开发指南（14）：消息驱动Bean - 编程入门网的所有评论
