EJB3.0如何使用MDB

Question

嗨，我是j2ee编码新手。我的问题是关于MDB。 我已经建立了我的weblogic 11g服务器。并且队列已经建立。

我已经写了客户端代码，它是一个java se客户端，向队列发送消息。

import java.util.Hashtable; 
import java.util.Properties; 

import javax.jms.Queue; 
import javax.jms.QueueConnection; 
import javax.jms.QueueConnectionFactory; 
import javax.jms.QueueSender; 
import javax.jms.QueueSession; 
import javax.jms.TextMessage; 
import javax.naming.Context; 
import javax.naming.InitialContext; 

public class MyMDBClient { 

    /** 
    * @param args 
    */ 
    public static void main(String[] args) { 
     QueueConnection cnn = null; 
      QueueSender sender = null; 
      QueueSession session = null; 
      InitialContext ctx; 
      Hashtable ht = new Hashtable(); 

      try { 
       ht.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory"); 
       ht.put(Context.PROVIDER_URL,"t3://localhost:7001"); 

       ctx = new InitialContext(ht); 
       Queue queue = (Queue) ctx.lookup("jms/testQueue"); 
       QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("jms/connectionFactory"); 
       cnn = factory.createQueueConnection(); 
       session = cnn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE); 
       TextMessage msg = session.createTextMessage(); 
       msg.setText("helloworld"); 
       sender = session.createSender(queue); 
       sender.send(msg); 

       System.out.println("Message sent successfully to remote queue."); 
       session.close(); // this is important. 
      } catch (Exception e) { 
       e.printStackTrace(); 
      } 
    } 
} 

我可以在我的weblogic管理控制台上看到队列中的消息。

但是，我的mdb在服务器端没有被调用。

谁能告诉我什么是错的。我更喜欢解决方案是在Java注释。谢谢大家阅读这个。

这里是我的服务器代码：

/** 
* import 
* 
*/ 

import javax.jms.JMSException; 
import javax.jms.Message; 
import javax.jms.MessageListener; 
import javax.jms.TextMessage; 

import weblogic.ejbgen.*; 


/** 
* Message-Driven Bean implementation class for: MyMDB 
* 
*/ 
@MessageDriven(ejbName="mdb", destinationType="javax.jms.queue",destinationJndiName="jms/testQueue" ) 
public class mdb implements MessageListener { 

    /** 
    * Default constructor. 
    */ 
    public mdb() { 
    } 

    /** 
    * @see MessageListener#onMessage(Message) 
    */ 
    public void onMessage(Message message) { 
     TextMessage tmsg = null; 
     tmsg = (TextMessage) message; 

     System.out.println("----------------"); 
     System.out.println("Received message : ");   
     try { 
      System.out.println(tmsg.getText()); 
     } catch (JMSException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 

     System.out.println("----------------");   
    } 
} 

Answer 1

这里是我有一个MDB注释是工作的一个例子：

@MessageDriven(
    messageListenerInterface = javax.jms.MessageListener.class, 
    name = "EventQueueListenerMDB", 
    mappedName = Constants.EVENT_QUEUE_JNDI, 
    activationConfig = { 
      @ActivationConfigProperty(
        propertyName = "connectionFactoryJndiName", 
        propertyValue = Constants.CONNECTION_FACTORY_JNDI), 
      @ActivationConfigProperty(
        propertyName = "destinationType", 
        propertyValue = "javax.jms.Queue") 
    }) 

而且，看来你的javax。 jms.queue不是javax.jms.Queue。