在Glassfish中不调用消息驱动Bean onMessage（）

Question

我对JMS编码是新手。我试图从独立的java客户端创建消息，该客户端创建并将消息发送到队列，消息驱动bean用于进一步处理消息。

我使用的是Glassfish应用服务器（3.1）。并设置从独立java客户机创建jms消息的所有内容。

下面是我的代码：客户端

import java.util.Properties;

import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueConnectionFactory;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;

public class TruckMonitor {

public static void main(String args[]) {

    try {

    // Provide the details of remote JMS Client
      Properties props = new Properties();
      props.put(Context.PROVIDER_URL, "mq://localhost:7676");

    // Create the initial context for remote JMS server
      InitialContext cntxt = new InitialContext(props);
      System.out.println("Context Created");

      // JNDI Lookup for QueueConnectionFactory in remote JMS Provider
      QueueConnectionFactory qFactory = (QueueConnectionFactory)cntxt.lookup("OmazanQueueConnectionFactory");

      // Create a Connection from QueueConnectionFactory
      Connection connection = qFactory.createConnection();
      System.out.println("Connection established with JMS Provide ");
      connection.start();
      // Initialise the communication session 
      Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
      // Create the message
      TextMessage message = session.createTextMessage();
      message.setJMSDeliveryMode(DeliveryMode.PERSISTENT);


      message.setText(getMessage());

      // JNDI Lookup for the Queue in remote JMS Provider
      Queue queue = (Queue)cntxt.lookup("OmazanQueue");

      // Create the MessageProducer for this communication 
      // Session on the Queue we have
      MessageProducer mp = session.createProducer(queue);

      // Send the message to Queue
      mp.send(message);
      System.out.println("Message Sent: " + getMessage());

      // Make sure all the resources are released 
      mp.close();
      session.close();
      cntxt.close();
  } catch (Exception ex) {
      ex.printStackTrace();
  }

}

private static String getMessage() {
    String msg = null;

    StringBuffer sbExceptionEvent = new StringBuffer("<exceptionEvent>");
    sbExceptionEvent.append("</exceptionEvent>");

    msg = sbExceptionEvent.toString();
    return msg;
}
}

消息驱动bean：

import java.util.Properties;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnectionFactory;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;


/** * Message-Driven Bean implementation class for: OmazanMDBean*/ 
@MessageDriven(
    activationConfig = { 
            @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"), 
            @ActivationConfigProperty(propertyName = "destination", propertyValue = "OmazanQueue"),
            @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge")
    }, 
    mappedName = "OmazanQueue")
public class OmazanMDBean implements MessageListener {

/**
 * Default constructor. 
 * @throws NamingException 
 * @throws JMSException 
 */
public OmazanMDBean() {
    super();
}

/**
 * @see MessageListener#onMessage(Message)
 */
public void onMessage(Message message) {
    System.out.println("Inside omMessage");
    try {
       message.acknowledge();
      } catch (Exception e) {
       e.printStackTrace();
    }

    TextMessage txtMessage = (TextMessage) message;

    try {
        System.out.println(txtMessage.getText());
    } catch (Exception e) {
       e.printStackTrace();
    }
}

}

问题是:onmessage()没有被调用。我错过什么了吗？请帮帮我.

Answer 1

我想如果您从MessageDrivenBean中删除@activationconfigproperty(propertyName=“destination”,propertyValue=“omazanqueue”），它就可以工作了，因为您已经使用了mappedName=“omazanqueue”