package com.wnq.mdbBean;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
@MessageDriven(
activationConfig = {
      //
      @ActivationConfigProperty(propertyName="connectionFactoryJndiName",propertyValue="jmsfactory"),
      //消息类型
      @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
      @ActivationConfigProperty(propertyName = "destination", propertyValue = "jmstest")
},
//这一句非常重要，给消息驱动Bean定义一个外部访问的JNDI名
mappedName = "jmstest")
public class MdbBean implements MessageListener {
      public MdbBean() {
      }
      public void onMessage(Message message) {
            TextMessage msg=(TextMessage)message;
            try {
                  System.out.println("MyQueueMDBBean被调用了"+msg.getText());
            } catch (JMSException e) {
                  e.printStackTrace();
            }
      }
}

3 客户端

客户端的作用是向weblogicJms发送消息。

package mdbBeanClient;
import java.util.Properties;
import javax.jms.JMSException;
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.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class MyQueueMDBBeanClient {
      public static void main(String[] args) throws JMSException {
            String url="t3://127.0.0.1:7001";
            Properties p=new Properties();
            p.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
            p.put(Context.PROVIDER_URL, url);
            try {
                  Context context=new InitialContext(p);
                  //获得JMS信息连接队列工厂
                  QueueConnectionFactory connFactory=(QueueConnectionFactory)context.lookup("jmsfactory");
                  //获得JMS信息链接队列
                  QueueConnection qConn=connFactory.createQueueConnection();
                  //产生队列session，设置事务模拟模式为false，自动应答消息接受
                  QueueSession qSession=qConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
                  qConn.start();
                  //获得队列
                  Queue queue=(Queue)context.lookup("jmstest");
                  //创建文本消息
                  TextMessage msg=qSession.createTextMessage("请问你是消息驱动Bean吗？<你终于接收到我的消息了，真的不简单啊，累死宝宝了！>");
                  QueueSender qSender=qSession.createSender(queue);
                  qSender.send(msg);
                  System.out.println("消息已经发送");
            } catch (NamingException e) {
                  e.printStackTrace();
            }
      }
}

4Eclipse截图

5weblogic控制台截图

Module named 'mdbBean2' failed to deploy. See Error Log view for more detail.

weblogic.application.ModuleException: Exception preparing module: EJBModule(mdbBean2)

Unable to deploy EJB: MyQueueMDBBean from mdbBean2:

[EJB:011113]Error: The Message Driven Bean 'MyQueueMDBBean(Application: mdbBean2, EJBComponent: mdbBean2)', does not have a message destination configured. The message destination must be set using a message-destination-link, destination-resource-link, destination-jndi-name or a resource-adapter-jndi-name.

Exception received from deployment driver. See Error Log view for more detail.