JBoss消息驱动bean，onMessage不叫

我正在开发一个使用JBoss 6.1作为后端的web应用程序。
我使用“目标”属性创建了一个消息驱动bean：“queue/searchtabQueue”和“目标类型”属性“javax.jms.Queue”。JBoss消息驱动bean，onMessage不叫

由于https://community.jboss.org/wiki/HowToCreateJMSQueuetopicInAS6下描述我设法创建我的队列 “队列/ searchtabQueue”（ “searchtab-将hornetq-jms.xml文件”）：

<configuration xmlns="urn:hornetq" 
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
      xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"> 
    <queue name="searchtabQueue"> 
    <entry name="/queue/searchtabQueue"/> 
    </queue> 
</configuration>

部署后，在管理控制台中，我看到了我在状态为“up”的“JMS队列”下排队。

在无状态Bean我做一下了队列，其工作原理是正确的，也发送抛出也不例外：

Context ctx = new InitialContext(p); // Create the initial context 
ConnectionFactory factory = (ConnectionFactory) ctx.lookup("ConnectionFactory"); 
Queue queue = (Queue) ctx.lookup("queue/searchtabQueue"); 
Connection connect = factory.createConnection(); 
javax.jms.Session session = connect.createSession(false, 0); 
MessageProducer sender = session.createProducer(queue); 
TextMessage msg = session.createTextMessage(); 
msg.setText("abc"); 
sender.send(msg); 
connect.close();

但该消息驱动Bean的onMessage方法不调用。

我错过了什么？

非常感谢提前

沃尔夫冈

更新：我MDB-代码：

我的消息驱动bean具有下面的代码：

@MessageDriven(activationConfig = { 
     @ActivationConfigProperty(propertyName = "destinationType", 
            propertyValue = "javax.jms.Queue"), 
     @ActivationConfigProperty(propertyName = "destination", 
            propertyValue = "queue/searchtabQueue"), 
     @ActivationConfigProperty(propertyName = "acknowledgeMode", 
            propertyValue = "Auto-acknowledge") 
    }) 
public class SearchTableBean implements MessageListener { 

    public void onMessage (Message message) { 
    } 
}

来源

2012-12-27 Wolfgang Adamec

你可以为你的MDB添加代码吗？这是一个远程队列吗？ – CoolBeans

Hello CoolBeans，我为我的MDB添加了代码 –

现在是工作，我改变了看法的东西。

查找代码：

Context ctx = new InitialContext(p); // Create the initial context 
Queue queue = (Queue) ctx.lookup("java:jboss/exported/jms/queue/searchtab"); 
QueueConnectionFactory factory = (QueueConnectionFactory) 
    ctx.lookup("ConnectionFactory"); 
QueueConnection connect = factory.createQueueConnection(); 
javax.jms.QueueSession session = connect.createQueueSession(false, 
    QueueSession.AUTO_ACKNOWLEDGE); 
TextMessage msg = session.createTextMessage("Hello World"); 
QueueSender sender = session.createSender(queue); 
sender.send(msg); 
connect.close();

队列创建XML文件：

<configuration xmlns="urn:hornetq" 
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
      xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"> 
    <queue name="searchtabQueue"> 
     <entry name="queue/searchtab"/> 
     <entry name="java:jboss/exported/jms/queue/searchtab"/> 
    </queue> 
</configuration>

MDB代码：

@MessageDriven(activationConfig = { 
     @ActivationConfigProperty(propertyName = "destinationType", 
            propertyValue = "javax.jms.Queue"), 
     @ActivationConfigProperty(propertyName = "destination", 
            propertyValue = "queue/searchtab"),  
     @ActivationConfigProperty(propertyName = "acknowledgeMode", 
            propertyValue = "Auto-acknowledge") 
    }) 
public class SearchTableBean implements MessageListener { 
    public void onMessage (Message message) { 
    System.out.println("abc"); 
}

来源

2013-01-09 15:04:08

根据该规范，则必须调用

connect.start();

来激活消息传递过程。

来源

2014-04-23 19:57:04 Alex

JBoss消息驱动bean，onMessage不叫

回答

相关问题