JMS/Glassfish - MDB 不使用队列消息

Question

我是第一次使用 JMS，并且使用 Glassfish 3.1.1。我已经设置了一个 JMS 连接工厂：

Pool Name: jms/QueueConnectionFactory
JNDI Name: jms/QueueConnectionFactory
Resource Type: javax.jms.QueueConnectionFactory

和一个目标资源：

JNDI Name: jms/ProcessBatchQueue
Physical Destination: ProcessBatchQueue
Resource Type: javax.jms.Queue

我已经部署了一个带有 servlet 的战争，该 servlet 接受文件，解析它并将内容保存到数据库。如果这一切都成功，它会向队列发送一条消息：

@Resource(lookup = "jms/ProcessBatchQueue")
private Queue processBatchQueue;

private void sendProcessBatchMessage(String batchID) throws JMSException
{
    log.info("Attempting to send process batch message for batch ID: "
            + batchID);

    Connection jmsConnection = connectionFactory.createConnection();
    Session jmsSession = jmsConnection.createSession(false,
            Session.AUTO_ACKNOWLEDGE);

    TextMessage message = jmsSession.createTextMessage();
    message.setText(batchID);

    MessageProducer msgProducer = jmsSession.createProducer(processBatchQueue);
    msgProducer.send(message);

    jmsConnection.close();
}

我部署了一个带有 MDB 的耳朵，它应该侦听队列并执行该消息：

@MessageDriven(mappedName = "jms/ProcessBatchQueue")
public class BatchReceiver
{
    private final Logger log = LoggerFactory.getLogger(BatchReceiver.class);

    public void onMessage(Message message)
    {
        log.info("Received message from jms/ProcessBatchQueue: " + message);

        try
        {
            if (message instanceof TextMessage)
            {
                String batchId = ((TextMessage) message).getText();
                // do processing
            }
            else
            {
                log.error("Received invalid message type from jms/ProcessBatchQueue");
            }
        }
        catch (Exception ex)
        {
            String error = "Received error '" + ex.toString()
                    + "' retrieving message from jms/BatchProcessingTopic.";

            Throwable linkedEx = ex.getCause();

            if (linkedEx != null)
            {
                log.error(error += "Linked exception: " + linkedEx.getMessage(),
                    linkedEx);
            }
            else
            {
                log.error(error + ", " + ex.getMessage(), ex);
            }
        }
    }
}

在我的战争日志中，我得到了该

log.info("Attempting to send process batch message for batch ID: " + batchID);

语句，但在耳朵日志中，我没有得到任何表明 MDB 正在接收消息的信息。

我的理解是，我应该能够“仅”使用 MDB 部署耳朵，并且它应该开始接收消息。我是否错过了某个配置步骤？

有没有某种方法可以确认 servlet 中生成的消息首先进入队列？包括 server.log 在内的任何日志中都没有错误。

Answer 1

您的 bean 没有实现 javax.jms.MessageListener，它只有一个具有相同签名的 onMessage() 方法。

您也可能错过了注释的 activationConfig 部分，但我不确定 Java EE 6 中是否需要它。看看是否是这样：

@MessageDriven(
    activationConfig = { 
            @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
            @ActivationConfigProperty(propertyName = "destination", propertyValue = "ProcessBatchQueue")},
    mappedName = "jms/ProcessBatchQueue")